Function process_readings

examples/NI DAQmx/daqbridge.py:118–149

Process raw voltage readings and return values for CSV output. Args: raw_data: numpy array of shape (num_channels, num_samples) with raw voltage readings channel_config: list of channel configuration dictionaries Returns: numpy array of shape (num_channels, num

(raw_data: np.ndarray, channel_config: list)

def process_readings(raw_data: np.ndarray, channel_config: list) -> np.ndarray:
    """
    Process raw voltage readings and return values for CSV output.

    Args:
        raw_data: numpy array of shape (num_channels, num_samples) with raw voltage readings
        channel_config: list of channel configuration dictionaries

    Returns:
        numpy array of shape (num_channels, num_samples) with processed values

    Default behavior:
        - Voltage channels: pass through as-is
        - Current channels: convert voltage to current using shunt resistor (I = V / R)

    Modify this function to add your custom processing logic.
    """
    output = raw_data.copy()

    for ch_idx, ch_cfg in enumerate(channel_config):
        if ch_cfg.get("type") == "current":
            shunt = ch_cfg.get("shunt_resistor", 1.0)
            output[ch_idx, :] = raw_data[ch_idx, :] / shunt  # I = V / R

    # -----------------------------------------------------
    # ADD YOUR CUSTOM PROCESSING HERE
    # Example:
    #   output[0, :] = raw_data[0, :] * 2.0  # Scale channel 0
    #   output[1, :] = np.clip(raw_data[1, :], -5, 5)  # Clamp channel 1
    # -----------------------------------------------------

    return output


# =============================================================================