This commit is contained in:
zhangshixiang
2025-07-19 23:12:37 +08:00
parent 6eba91efc5
commit bc00aba2ee
7 changed files with 135 additions and 7 deletions

View File

@@ -166,7 +166,7 @@ class MQTTClient:
status = {"data": device_status.get(device_id, {}), "device_id": device_id, "timestamp": time.time()}
address = f"labs/{MQConfig.lab_id}/devices/"
self.client.publish(address, json.dumps(status), qos=2)
logger.info(f"Device status published: address: {address}, {status}")
logger.info(f"Device {device_id} status published: address: {address}, {status}")
def publish_job_status(self, feedback_data: dict, job_id: str, status: str, return_info: Optional[str] = None):
if self.mqtt_disable: