hasslesstech/IoT-Systems
1
0
Fork 0
Code Issues Pull Requests Actions Activity

fix: improve logging clarity and ensure data delivery in AgentMQTTAdapter

Browse Source
This commit is contained in:
esk4nz
2026-03-23 23:41:25 +02:00
parent e8ff1c6cbd
commit b12bdc334c
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
edge/app/adapters/agent_mqtt_adapter.py
View File

@@ -39,12 +39,13 @@ class AgentMQTTAdapter(AgentGateway):
agent_data = AgentData.model_validate_json(payload, strict=True) agent_data = AgentData.model_validate_json(payload, strict=True)
# Process the received data (you can call a use case here if needed) # Process the received data (you can call a use case here if needed)
processed_data = process_agent_data(agent_data) processed_data = process_agent_data(agent_data)
# Store the agent_data in the database (you can send it to the data processing module) # Attempt to send processed data to the Hub gateway
if processed_data is not None: if self.hub_gateway.save_data(processed_data):
if not self.hub_gateway.save_data(processed_data): # Log successful transmission as INFO level
logging.error("Hub is not available") logging.info("Processed data successfully forwarded to the Hub.")
else: else:
logging.info("Road is fine, no data sent to hub.") # Log Hub unavailability or transmission failure as ERROR level
logging.error("Failed to send data: Hub gateway is unavailable.")
except Exception as e: except Exception as e:
logging.info(f"Error processing MQTT message: {e}") logging.info(f"Error processing MQTT message: {e}")