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