File tree Expand file tree Collapse file tree 3 files changed +7
-7
lines changed
Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 1- # Borzoi
1+ # kafka_dae_control
22
3- Borzoi like running. This listens to ISISDAE's start/stop times and pushes start/stop Flatbuffer blobs to Kafka accordingly.
3+ This is a FastCS IOC responsible for communicating with the acquisition hardware and pushing start/stop Flatbuffer blobs to Kafka accordingly.
Original file line number Diff line number Diff line change 1111from streaming_data_types .run_start_pl72 import serialise_pl72
1212from streaming_data_types .run_stop_6s4t import serialise_6s4t
1313
14- logger = logging .getLogger ("borzoi " )
14+ logger = logging .getLogger ("KDAECTRL " )
1515logging .basicConfig (level = logging .INFO )
1616
1717
@@ -181,8 +181,8 @@ def main() -> None:
181181 if prefix is None or instrument_name is None :
182182 raise ValueError ("prefix or instrument name not set - have you run config_env.bat?" )
183183
184- broker = os .environ .get ("BORZOI_KAFKA_BROKER " , "livedata.isis.cclrc.ac.uk:31092" )
185- topic = os .environ .get ("BORZOI_TOPIC " , f"{ instrument_name } _runInfo" )
184+ broker = os .environ .get ("KDAECTRL_KAFKA_BROKER " , "livedata.isis.cclrc.ac.uk:31092" )
185+ topic = os .environ .get ("KDAECTRL_TOPIC " , f"{ instrument_name } _runInfo" )
186186 logger .info ("setting up producer" )
187187 loop = asyncio .new_event_loop ()
188188 producer = loop .run_until_complete (set_up_producer (broker ))
Original file line number Diff line number Diff line change 11[project ]
2- name = " borzoi "
2+ name = " kafka_dae_control "
33version = " 0.1.0"
4- description = " Start and stop runs."
4+ description = " Data streaming software for communicating with the detector hardware and start and stop kafka runs."
55readme = " README.md"
66requires-python = " >=3.11"
77dependencies = [
You can’t perform that action at this time.
0 commit comments