kafka_dae_diagnostics.kafka.handlers

Utilities for reacting to Kafka messages.

Members

handle_6s4t	Handle a 6s4t (run stop) message from Kafka.
handle_ev44	Handle an ev44 (event-data) message from Kafka.
handle_event_messages	Handle Kafka event messages.
handle_event_msg	Handle an arbitrary message from Kafka event topic.
handle_pl72	Handle a pl72 (run start) message from Kafka.
handle_run_info_messages	Handle Kafka run info messages.
handle_runinfo_msg	Handle an arbitrary message from Kafka runInfo topic.

kafka_dae_diagnostics.kafka.handlers.handle_6s4t(data: Data, msg: bytes) → None

Handle a 6s4t (run stop) message from Kafka.

kafka_dae_diagnostics.kafka.handlers.handle_ev44(data: Data, msg: bytes) → None

Handle an ev44 (event-data) message from Kafka.

Parameters:

• data – Reference to data being served.

• msg – Message bytes received from Kafka.

kafka_dae_diagnostics.kafka.handlers.handle_event_messages(event_messages: list[Message], data: Data) → None

Handle Kafka event messages.

Parameters:

• event_messages – Messages received from Kafka event topic.

• data – Data served by kafka_dae_diagnostics.

kafka_dae_diagnostics.kafka.handlers.handle_event_msg(data: Data, msg: bytes) → None

Handle an arbitrary message from Kafka event topic.

Parameters:

• data – Reference to data being served.

• msg – Message bytes received from Kafka.

kafka_dae_diagnostics.kafka.handlers.handle_pl72(data: Data, msg: bytes, event_consumer: Consumer) → None

Handle a pl72 (run start) message from Kafka.

This zeroes the spectra array (reallocating if the size changed), and configures the event consumer to re-read all events since run start (in case run start timestamp was in the past).

Parameters:

• data – Reference to data being served.

• msg – Message bytes received from Kafka.

• event_consumer – Kafka event topic consumer.

kafka_dae_diagnostics.kafka.handlers.handle_run_info_messages(run_info_messages: list[Message], data: Data, event_consumer: Consumer) → None

Handle Kafka run info messages.

Parameters:

• run_info_messages – Messages received from Kafka runInfo topic.

• data – Data served by kafka_dae_diagnostics.

• event_consumer – Consumer for event Kafka topic.

kafka_dae_diagnostics.kafka.handlers.handle_runinfo_msg(data: Data, msg: bytes, event_consumer: Consumer) → None

Handle an arbitrary message from Kafka runInfo topic.

Parameters:

• data – Reference to data being served.

• msg – Message bytes received from Kafka.

• event_consumer – Kafka event topic consumer.