kafka_dae_diagnostics.kafka.consumers

Kafka consumers.

Members

consume_from_kafka_forever	Consume from Kafka forever.
make_event_consumer	Make an event consumer.
make_runinfo_consumer	Make a runInfo consumer.
run_callbacks	Run all callbacks with updated data.

kafka_dae_diagnostics.kafka.consumers.consume_from_kafka_forever(config: DiagnosticsConfig, data: Data) → None

Consume from Kafka forever.

Parameters:

• config – Diagnostics IOC configuration parameters

• data – The data to serve.

kafka_dae_diagnostics.kafka.consumers.make_event_consumer(config: DiagnosticsConfig) → Consumer

Make an event consumer.

kafka_dae_diagnostics.kafka.consumers.make_runinfo_consumer(config: DiagnosticsConfig) → Consumer

Make a runInfo consumer.

This consumer will start reading from the 2 most recent messages on the runInfo topic; one of these messages should include the most recent run start (pl72) message, which will cause kafka_dae_diagnostics to correctly configure itself for the current (perhaps in-progress) run on startup.

kafka_dae_diagnostics.kafka.consumers.run_callbacks(data: Data) → None

Run all callbacks with updated data.

These callbacks will push new values to PVs.

Parameters:

data – The data to serve