Publishers: publish file

"""Example: Publishers: publish file.

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

"""

import time

from instro.daq import InstroDAQ
from instro.daq.drivers.labjack import LabJackTSeriesDriver
from instro.daq.types import Direction
from instro.lib.publishers import FilePublisher

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

daq = InstroDAQ(
    name="myDAQ",
    driver=LabJackTSeriesDriver(device_id="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()