smia.logic.intra_aas_interactions_utils module

This class groups the methods related to the Intra AAS interactions between the Manager and the Core.

smia.logic.intra_aas_interactions_utils.save_svc_info_in_log_file(requested_entity, svc_type_log_file_name, interaction_id_num)[source]

This method saves the information of a service request in the associated log file.

Parameters:
  • requested_entity (str) – The entity that has requested the service, to know in which interaction files to search.

  • svc_type_log_file_name (str) – The log file name of the service type.

  • interaction_id_num (int) – Identifier of the interaction.

smia.logic.intra_aas_interactions_utils.create_interaction_kafka_consumer(client_id)[source]

This method creates the Kafka consumer for subscribing to AAS Core partition in the topic of the AAS. :param client_id: the id of the client of the Kafka consumer. :type client_id: str

Returns:

the object of the Kafka consumer.

Return type:

AIOKafkaConsumer