Skip to content

E
ems_collector
Commit da0ba8f2 authored by ZZH's avatar ZZH
Browse files
Options

add log 2026-4-30 17:00

parent 1446db46
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
src/ems_water_grp/ems.py
View file @ da0ba8f2
...@@ -274,6 +274,8 @@ class WaterGrpService: ...@@ -274,6 +274,8 @@ class WaterGrpService:
payload = transfer_realtime(pyd, data_lst) payload = transfer_realtime(pyd, data_lst)
topic = ETYPE_TOPIC[pyd["equipmentType"]] topic = ETYPE_TOPIC[pyd["equipmentType"]]
topic = f"{self.topic_prefix}{topic}/{pyd['equipmentCode']}" topic = f"{self.topic_prefix}{topic}/{pyd['equipmentCode']}"
logger.info(f"Pub {topic}, pyd: {payload}")
self.mqtt_client.publish(topic, payload)
self.mqtt_client.publish(topic, json.dumps(payload), qos=1) self.mqtt_client.publish(topic, json.dumps(payload), qos=1)
pub_cnt += 1 pub_cnt += 1
except Exception as e: except Exception as e:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment