Aggregator

$ python -m larpixdaq.aggregator --help
usage: aggregator.py [-h] [--core CORE] [--log-address LOG_ADDRESS] [-d]
                     address

Launch the data aggregator for LArPix DAQ

positional arguments:
  address               The address to publish data to including port number

optional arguments:
  -h, --help            show this help message and exit
  --core CORE           The address of the DAQ Core, not including port number
  --log-address LOG_ADDRESS
                        Address to connect to global log, including port
                        number
  -d, --debug           Enter debug (verbose) mode
class larpixdaq.aggregator.LArPixAggregator(output_address, core_address, log_address)[source]

The data aggregator for LArPix.

The aggregator connects the producer (LArPix board) to any number of data consumers such as data monitor and offline storage.

In the future, the aggregator will support receiving data from multiple LArPix boards.

Example invocation:

python -m larpixdaq.aggregator tcp://127.0.0.1:50002
Variables
  • aggregator – the xylem Aggregator object

  • state – the DAQ state of the xylem Aggregator component

Parameters
  • output_address – the full TCP address (including port number) that data will be published to

  • core_address – the full TCP address (including port number) of the DAQ core

  • log_address – the full TCP address (including port number) of the DAQ Log

run()[source]

Initiate the event loop of reading and rebroadcasting messages and data.