Example: Publishers: publish file.

```python """Example: Publishers: publish file.

Demonstrates publishing measurements to a local Avro file (FilePublisher).

"""

import time

from nominal_instro.instruments import NominalDAQ from nominal_instro.instruments.daq.types import DAQVendor, Direction from nominal_instro.lib.publishers import FilePublisher

AO_CH0 = "DAC0" AO_CH1 = "DAC1" AI_CH0 = "AIN0" AI_CH1 = "AIN1"

daq = NominalDAQ.create( name="myDAQ", vendor=DAQVendor.LABJACK_T_SERIES, resource="440023835", publishers=[FilePublisher(directory="./captures", format="avro", custom_file_name="test_file")] )

daq.open()

daq.configure_analog_channel(direction=Direction.INPUT, physical_channel=AI_CH0, alias="ai_0", range_min=0, range_max=5) daq.configure_analog_channel(direction=Direction.INPUT, physical_channel=AI_CH1, alias="ai_1", range_min=0, range_max=5) daq.configure_analog_channel(direction=Direction.OUTPUT, physical_channel=AO_CH0, alias="ao_0", range_min=0, range_max=5) daq.configure_analog_channel(direction=Direction.OUTPUT, physical_channel=AO_CH1, alias="ao_1", range_min=0, range_max=5) daq.configure_ai_sample_rate(sample_rate=100)

daq.start()

try: while True: try: ai_0 = daq.get_channel("myDAQ.ai_0", 1, True).latest ai_1 = daq.get_channel("myDAQ.ai_1", 1, True).latest print(f"ai_0: {ai_0} ai_1: {ai_1}") time.sleep(1) except KeyboardInterrupt: break daq.stop() finally: daq.close()```