add log 2026-5-22 14:19

src/ems_water_grp/ems.py

@@ -381,6 +381,6 @@ async def main():
 if __name__ == "__main__":
     logger.info("水务集团采集服务 (基于 httpx) 正在启动...")
     try:
-        asyncio.run(tools())
+        asyncio.run(main())
     except KeyboardInterrupt:
         logger.info("进程被用户手动终止。")

src/ems_water_grp/meter_3rd.py

@@ -93,11 +93,15 @@ class Meter3rdForward:
                 except Exception as e:
                     continue
 
+            cnt = 0
             for sid, payload in d_pyds.items():
                 logger.info(f"{sid}: {payload}")
                 self.client_pub.publish(
                     f"{self.pub_topic_prefix}/load_ele/{sid}",
                     json.dumps(payload), qos=1)
+                cnt += 1
+
+            logger.info(f"forward fid:{fid} {cnt} msgs")
         except Exception as e:
             logger.error(f"parse_and_forward error: {e}")