Commit ea9455a4 authored by ZZH's avatar ZZH

add log 2026-6-25 14:18

parent 330c0b35
...@@ -69,6 +69,7 @@ class Meter3rdForward: ...@@ -69,6 +69,7 @@ class Meter3rdForward:
data = json.loads(msg_str) data = json.loads(msg_str)
fId = data.get("fId") fId = data.get("fId")
if fId: if fId:
logger.info(f"fId:{fId}, {data}")
self.d_last_msg[fId] = msg_str self.d_last_msg[fId] = msg_str
except Exception as e: except Exception as e:
logger.error(f"Decode msg:{payload} error: {e}") logger.error(f"Decode msg:{payload} error: {e}")
...@@ -108,7 +109,7 @@ class Meter3rdForward: ...@@ -108,7 +109,7 @@ class Meter3rdForward:
cnt = 0 cnt = 0
for sid, payload in d_pyds.items(): for sid, payload in d_pyds.items():
logger.info(f"{sid}: {payload}") # logger.info(f"{sid}: {payload}")
topic = await self.parse_topic(sid) topic = await self.parse_topic(sid)
if not topic: if not topic:
logger.error(f"Parse topic {sid} failed, pyd:{payload}") logger.error(f"Parse topic {sid} failed, pyd:{payload}")
......
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