Real-time DSP processing pipeline in Signal Processing - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to initialize the audio input stream.

Signal Processing

audio_stream = AudioStream(sample_rate=[1], channels=1)

Drag options to blanks, or click blank then click option'

A48000

B44100

C22050

D96000

Attempts:

3 left

💡 Hint

Common Mistakes

Choosing too low or too high sample rates that affect quality or latency.

The standard sample rate for real-time DSP audio processing is 48000 Hz for good quality and low latency.

2fill in blank

medium

Complete the code to apply a low-pass filter to the signal.

Signal Processing

filtered_signal = low_pass_filter(signal, cutoff_freq=[1])

Drag options to blanks, or click blank then click option'

A10000

B2000

C5000

D1500

Attempts:

3 left

💡 Hint

Common Mistakes

Setting cutoff too high or too low, causing distortion or insufficient filtering.

A cutoff frequency of 2000 Hz is typical for removing high-frequency noise in audio signals.

3fill in blank

hard

Fix the error in the code to compute the FFT of the signal.

Signal Processing

spectrum = np.fft.[1](signal)

Drag options to blanks, or click blank then click option'

Arfft

Bfftshift

Cifft

Dfft

Attempts:

3 left

💡 Hint

Common Mistakes

Using inverse FFT or shift functions instead of FFT.

The correct function to compute the Fast Fourier Transform is fft.

4fill in blank

hard

Fill both blanks to create a dictionary comprehension that maps frequencies to magnitudes above threshold.

Signal Processing

freq_magnitude = {freq: mag for freq, mag in zip(frequencies, magnitudes) if mag [1] threshold and freq [2] 0}

Drag options to blanks, or click blank then click option'

A>

B<

C>=

D<=

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong comparison signs causing empty or incorrect dictionaries.

We want magnitudes greater than the threshold and frequencies greater or equal to zero.

5fill in blank

hard

Fill all three blanks to create a dictionary comprehension that maps frequency bands to average power above a limit.

Signal Processing

power_bands = {band[1]: np.mean(powers) [2] band_powers.items() if avg_power [3] limit}

Drag options to blanks, or click blank then click option'

A for band, avg_power

B for band, powers

C>

D<

Attempts:

3 left

💡 Hint

Common Mistakes

Mixing variable names or using wrong comparison operators.

The comprehension iterates over band and powers, calculates average power, and filters by power greater than limit.

Practice

1. What is the main purpose of a real-time DSP processing pipeline?

easy

A. To process signals step-by-step as data arrives

B. To store large amounts of data for later analysis

C. To generate random signals for testing

D. To visualize signals after processing is complete

Solution

1. Step 1: Understand real-time processing

   Real-time DSP means processing data immediately as it comes in, not storing for later.

2. Step 2: Identify pipeline purpose

   The pipeline processes signals step-by-step to analyze or clean them on the fly.

3. Final Answer:

   To process signals step-by-step as data arrives -> Option A

4. Quick Check:

   Real-time DSP = step-by-step processing [OK]

Hint: Real-time means processing data immediately as it arrives [OK]

Common Mistakes:

• Confusing real-time with batch processing
• Thinking pipeline stores data only
• Assuming visualization is the main goal

2. Which of the following is the correct syntax to apply a moving average filter on a signal array data in Python using a window size of 3?

easy

A. filtered = [sum(data[i:i+3])*3 for i in range(len(data)-2)]

B. filtered = [sum(data[i:i+3])/3 for i in range(len(data)-2)]

C. filtered = [sum(data[i:i+3])/3 for i in range(len(data)+2)]

D. filtered = sum(data[i:i+3])/3 for i in range(len(data)-2)

Solution

1. Step 1: Understand moving average filter

   It averages each group of 3 consecutive elements in the data.

2. Step 2: Check syntax correctness

   filtered = [sum(data[i:i+3])/3 for i in range(len(data)-2)] correctly uses list comprehension with range(len(data)-2) and divides sum by 3.

3. Final Answer:

   filtered = [sum(data[i:i+3])/3 for i in range(len(data)-2)] -> Option B

4. Quick Check:

   Correct list comprehension with proper range and division [OK]

Hint: Use range(len(data)-window+1) for correct slicing [OK]

Common Mistakes:

• Missing brackets for list comprehension
• Using wrong range length causing index errors
• Multiplying instead of dividing for average

3. Given the Python code below for a simple real-time DSP pipeline, what is the output of print(filtered_signal)?

signal = [1, 3, 5, 7, 9]
window_size = 2
filtered_signal = [ (signal[i] + signal[i+1]) / 2 for i in range(len(signal)-1) ]
print(filtered_signal)

medium

A. [1.0, 4.0, 6.0, 8.0]

B. [1.0, 3.0, 5.0, 7.0, 9.0]

C. [2.0, 4.0, 6.0, 8.0]

D. [3.0, 5.0, 7.0, 9.0]

Solution

1. Step 1: Understand the list comprehension

   It averages each pair of consecutive elements: (signal[i] + signal[i+1]) / 2.

2. Step 2: Calculate each average

   Pairs: (1+3)/2=2.0, (3+5)/2=4.0, (5+7)/2=6.0, (7+9)/2=8.0.

3. Final Answer:

   [2.0, 4.0, 6.0, 8.0] -> Option C

4. Quick Check:

   Pairwise averages = [2.0, 4.0, 6.0, 8.0] [OK]

Hint: Calculate pair averages step-by-step [OK]

Common Mistakes:

• Including last element without pair
• Confusing sum with average
• Wrong range causing index error

4. The following code attempts to implement a moving average filter but raises an error. What is the error and how to fix it?

data = [2, 4, 6, 8]
window = 3
filtered = []
for i in range(len(data)):
    avg = (data[i] + data[i+1] + data[i+2]) / window
    filtered.append(avg)
print(filtered)

medium

A. IndexError because indexing goes beyond list end; fix by using range(len(data)-window+1)

B. ZeroDivisionError because window is zero; fix by setting window to 1

C. TypeError because sum cannot add list slices; fix by converting slice to list

D. No error; code runs correctly

Solution

1. Step 1: Identify the error cause

   Loop runs till len(data), but indexing data[i+2] exceeds list length at end.

2. Step 2: Fix the loop range

   Change loop to range(len(data)-window+1) to avoid out-of-range indexing.

3. Final Answer:

   IndexError because indexing goes beyond list end; fix by using range(len(data)-window+1) -> Option A

4. Quick Check:

   Loop range must prevent out-of-bound indexing [OK]

Hint: Loop till len(data)-window+1 for safe indexing [OK]

Common Mistakes:

• Ignoring index bounds causing IndexError
• Changing window size incorrectly
• Assuming no error occurs

5. You want to build a real-time DSP pipeline that filters noise from a sensor signal using a moving average filter of window size 4, but the sensor sometimes sends fewer than 4 samples at once. How should you adapt your pipeline to handle this situation correctly?

hard

A. Use a fixed window size of 1 to avoid buffering

B. Apply the filter on whatever samples arrive, even if fewer than 4, without buffering

C. Discard any samples fewer than 4 and wait for a full batch

D. Process only when at least 4 samples are available; buffer incoming data until then

Solution

1. Step 1: Understand window size requirement

   Moving average with window 4 needs 4 samples to compute an average.

2. Step 2: Handle fewer samples in real-time

   Buffer incoming samples until at least 4 are collected, then apply filter.

3. Step 3: Avoid incorrect averages

   Processing fewer samples without buffering gives wrong results; discarding loses data.

4. Final Answer:

   Process only when at least 4 samples are available; buffer incoming data until then -> Option D

5. Quick Check:

   Buffering ensures correct window size for filtering [OK]

Hint: Buffer data until window size reached before filtering [OK]

Common Mistakes:

• Filtering with incomplete windows causing errors
• Discarding useful data
• Using window size 1 losing noise reduction benefits