smartem_backend.consumer

Members

get_active_agent_sessions	Get all currently active agent sessions
get_event_handlers	Get a mapping of event types to their handler functions
handle_acquisition_created	Handle acquisition created event by logging the event payload
handle_acquisition_deleted	Handle acquisition deleted event by logging the event payload
handle_acquisition_updated	Handle acquisition updated event by logging the event payload
handle_agent_instruction_created	Handle agent instruction created event by persisting the instruction to the database
handle_agent_instruction_expired	Handle agent instruction expired event by updating retry logic and status
handle_agent_instruction_updated	Handle agent instruction updated event by updating the instruction status
handle_atlas_created	Handle atlas created event by logging the event payload
handle_atlas_deleted	Handle atlas deleted event by logging the event payload
handle_atlas_updated	Handle atlas updated event by logging the event payload
handle_ctf_estimation_complete
handle_external_foilhole_model_prediction	Handle external foilhole model prediction event by generating agent instructions
handle_external_gridsquare_model_prediction	Handle external grid square model prediction event by generating agent instructions
handle_foilhole_created	Handle foilhole created event by logging the event payload and generating predictions
handle_foilhole_deleted	Handle foilhole deleted event by logging the event payload
handle_foilhole_model_prediction	Handle foil hole model prediction event by inserting the result into the database
handle_foilhole_model_prediction_router	Route foilhole model prediction events based on source
handle_foilhole_updated	Handle foilhole updated event by logging the event payload
handle_grid_created	Handle grid created event by logging the event payload and initialising prediction model weights
handle_grid_deleted	Handle grid deleted event by logging the event payload
handle_grid_registered	Handle grid registered event by logging the event payload
handle_grid_updated	Handle grid updated event by logging the event payload
handle_gridsquare_created	Handle gridsquare created event by logging the event payload and generating predictions
handle_gridsquare_deleted	Handle gridsquare deleted event by logging the event payload
handle_gridsquare_lowmag_created	Handle low mag gridsquare created event by logging the event payload and generating predictions
handle_gridsquare_lowmag_deleted	Handle low mag gridsquare deleted event by logging the event payload
handle_gridsquare_lowmag_updated	Handle gridsquare low mag updated event by logging the event payload
handle_gridsquare_model_prediction	Handle grid square model prediction event by inserting the result into the database
handle_gridsquare_model_prediction_router	Route gridsquare model prediction events based on source
handle_gridsquare_registered	Handle grid square registered event by logging the event payload
handle_gridsquare_updated	Handle gridsquare updated event by logging the event payload
handle_micrograph_created	Handle micrograph created event by logging the event payload and starting processing simulation
handle_micrograph_deleted	Handle micrograph deleted event by logging the event payload
handle_micrograph_updated	Handle micrograph updated event by logging the event payload
handle_model_parameter_update	Handle model parameter update event by inserting the result into the database
handle_motion_correction_complete
handle_multi_foilhole_model_prediction	Handle multiple foil hole model predictions event by inserting the result into the database
handle_refresh_predictions	Handle refresh predictions event by calculating the updated values
main	Main function to run the consumer
on_message	Callback function for processing RabbitMQ messages
signal_handler	Handle shutdown signals

smartem_backend.consumer.handle_acquisition_created(event_data: dict[str, Any]) → None

Handle acquisition created event by logging the event payload

Parameters:

event_data – Event data for acquisition created

smartem_backend.consumer.handle_acquisition_updated(event_data: dict[str, Any]) → None

Handle acquisition updated event by logging the event payload

Parameters:

event_data – Event data for acquisition updated

smartem_backend.consumer.handle_acquisition_deleted(event_data: dict[str, Any]) → None

Handle acquisition deleted event by logging the event payload

Parameters:

event_data – Event data for acquisition deleted

smartem_backend.consumer.handle_atlas_created(event_data: dict[str, Any]) → None

Handle atlas created event by logging the event payload

Parameters:

event_data – Event data for atlas created

smartem_backend.consumer.handle_atlas_updated(event_data: dict[str, Any]) → None

Handle atlas updated event by logging the event payload

Parameters:

event_data – Event data for atlas updated

smartem_backend.consumer.handle_atlas_deleted(event_data: dict[str, Any]) → None

Handle atlas deleted event by logging the event payload

Parameters:

event_data – Event data for atlas deleted

smartem_backend.consumer.handle_grid_created(event_data: dict[str, Any], channel, delivery_tag) → bool

Handle grid created event by logging the event payload and initialising prediction model weights

Parameters:

• event_data – Event data for grid created

• channel – RabbitMQ channel

• delivery_tag – Message delivery tag

Returns:

True if successful, False if failed (already NACKed)

Return type:

bool

smartem_backend.consumer.handle_grid_updated(event_data: dict[str, Any]) → None

Handle grid updated event by logging the event payload

Parameters:

event_data – Event data for grid updated

smartem_backend.consumer.handle_grid_deleted(event_data: dict[str, Any]) → None

Handle grid deleted event by logging the event payload

Parameters:

event_data – Event data for grid deleted

smartem_backend.consumer.handle_grid_registered(event_data: dict[str, Any]) → None

Handle grid registered event by logging the event payload

Parameters:

event_data – Event data for grid registered

smartem_backend.consumer.handle_gridsquare_lowmag_created(event_data: dict[str, Any], channel, delivery_tag) → bool

Handle low mag gridsquare created event by logging the event payload and generating predictions

Parameters:

• event_data – Event data for low mag gridsquare created

• channel – RabbitMQ channel

• delivery_tag – Message delivery tag

Returns:

True if successful, False if failed (already NACKed)

Return type:

bool

smartem_backend.consumer.handle_gridsquare_created(event_data: dict[str, Any], channel, delivery_tag) → bool

Handle gridsquare created event by logging the event payload and generating predictions

Parameters:

• event_data – Event data for gridsquare created

• channel – RabbitMQ channel

• delivery_tag – Message delivery tag

Returns:

True if successful, False if failed (already NACKed)

Return type:

bool

smartem_backend.consumer.handle_gridsquare_lowmag_updated(event_data: dict[str, Any]) → None

Handle gridsquare low mag updated event by logging the event payload

Parameters:

event_data – Event data for low mag gridsquare updated

smartem_backend.consumer.handle_gridsquare_updated(event_data: dict[str, Any]) → None

Handle gridsquare updated event by logging the event payload

Parameters:

event_data – Event data for gridsquare updated

smartem_backend.consumer.handle_gridsquare_lowmag_deleted(event_data: dict[str, Any]) → None

Handle low mag gridsquare deleted event by logging the event payload

Parameters:

event_data – Event data for low mag gridsquare deleted

smartem_backend.consumer.handle_gridsquare_deleted(event_data: dict[str, Any]) → None

Handle gridsquare deleted event by logging the event payload

Parameters:

event_data – Event data for gridsquare deleted

smartem_backend.consumer.handle_gridsquare_registered(event_data: dict[str, Any]) → None

Handle grid square registered event by logging the event payload

Parameters:

event_data – Event data for grid square registered

smartem_backend.consumer.handle_foilhole_created(event_data: dict[str, Any], channel, delivery_tag) → bool

Handle foilhole created event by logging the event payload and generating predictions

Parameters:

• event_data – Event data for foilhole created

• channel – RabbitMQ channel

• delivery_tag – Message delivery tag

Returns:

True if successful, False if failed (already NACKed)

Return type:

bool

smartem_backend.consumer.handle_foilhole_updated(event_data: dict[str, Any]) → None

Handle foilhole updated event by logging the event payload

Parameters:

event_data – Event data for foilhole updated

smartem_backend.consumer.handle_foilhole_deleted(event_data: dict[str, Any]) → None

Handle foilhole deleted event by logging the event payload

Parameters:

event_data – Event data for foilhole deleted

smartem_backend.consumer.handle_micrograph_created(event_data: dict[str, Any], channel, delivery_tag) → bool

Handle micrograph created event by logging the event payload and starting processing simulation

Parameters:

• event_data – Event data for micrograph created

• channel – RabbitMQ channel

• delivery_tag – Message delivery tag

Returns:

True if successful, False if failed (already NACKed)

Return type:

bool

smartem_backend.consumer.handle_micrograph_updated(event_data: dict[str, Any]) → None

Handle micrograph updated event by logging the event payload

Parameters:

event_data – Event data for micrograph updated

smartem_backend.consumer.handle_micrograph_deleted(event_data: dict[str, Any]) → None

Handle micrograph deleted event by logging the event payload

Parameters:

event_data – Event data for micrograph deleted

smartem_backend.consumer.handle_gridsquare_model_prediction(event_data: dict[str, Any]) → None

Handle grid square model prediction event by inserting the result into the database

Parameters:

event_data – Event data for grid square model prediction

smartem_backend.consumer.handle_foilhole_model_prediction(event_data: dict[str, Any]) → None

Handle foil hole model prediction event by inserting the result into the database

Parameters:

event_data – Event data for foil hole model prediction

smartem_backend.consumer.handle_multi_foilhole_model_prediction(event_data: dict[str, Any]) → None

Handle multiple foil hole model predictions event by inserting the result into the database

Parameters:

event_data – Event data for foil hole model predictions

smartem_backend.consumer.handle_refresh_predictions(event_data: dict[str, Any]) → None

Handle refresh predictions event by calculating the updated values

Parameters:

event_data – Event data for refresh predictions event

smartem_backend.consumer.handle_model_parameter_update(event_data: dict[str, Any]) → None

Handle model parameter update event by inserting the result into the database

Parameters:

event_data – Event data for model parameter update

smartem_backend.consumer.handle_external_gridsquare_model_prediction(event_data: dict[str, Any]) → None

Handle external grid square model prediction event by generating agent instructions

Parameters:

event_data – External event data with payload containing prediction results

smartem_backend.consumer.handle_external_foilhole_model_prediction(event_data: dict[str, Any]) → None

Handle external foilhole model prediction event by generating agent instructions

Parameters:

event_data – External event data with payload containing prediction results

smartem_backend.consumer.get_active_agent_sessions()

Get all currently active agent sessions

smartem_backend.consumer.handle_gridsquare_model_prediction_router(event_data: dict[str, Any]) → None

Route gridsquare model prediction events based on source

smartem_backend.consumer.handle_foilhole_model_prediction_router(event_data: dict[str, Any]) → None

Route foilhole model prediction events based on source

smartem_backend.consumer.handle_agent_instruction_created(event_data: dict[str, Any]) → None

Handle agent instruction created event by persisting the instruction to the database

Parameters:

event_data – Event data for agent instruction created

smartem_backend.consumer.handle_agent_instruction_updated(event_data: dict[str, Any]) → None

Handle agent instruction updated event by updating the instruction status

Parameters:

event_data – Event data for agent instruction updated

smartem_backend.consumer.handle_agent_instruction_expired(event_data: dict[str, Any]) → None

Handle agent instruction expired event by updating retry logic and status

Parameters:

event_data – Event data for agent instruction expired

smartem_backend.consumer.get_event_handlers() → dict[str, Callable]

Get a mapping of event types to their handler functions

Returns:

Mapping of event type strings to handler functions

Return type:

Dict[str, Callable]

smartem_backend.consumer.on_message(ch, method, properties, body)

Callback function for processing RabbitMQ messages

Parameters:

• ch – Channel object

• method – Method object

• properties – Properties object

• body – Message body

smartem_backend.consumer.signal_handler(signum, frame)

Handle shutdown signals

smartem_backend.consumer.main()

Main function to run the consumer