sid iccid add log 2025-6-6 16:30

unify_api/modules/zhiwei_u/service/sid_iccid_map.py

@@ -9,6 +9,7 @@ import time
 from uuid import uuid4
 import pendulum
 import asyncio
+import logging
 from pot_libs.aiomqtt_util.hbmqtt_utils import MqttUtil
 from pot_libs.mysql_util.mysql_util import MysqlUtil
 
@@ -185,7 +186,7 @@ async def load_iccid(sid):
 async def update_all():
     sid_iccids, fail_sid, tmp = [], set(), []
     sid_total = await load_all_sids()
-    print(f"start at {pendulum.now()}, sid total：{len(sid_total)}")
+    logging.info(f"start at {pendulum.now()}, sid total：{len(sid_total)}")
     for i, sid in enumerate(sid_total, start=1):
         tmp.append(sid)
         if i % 100 and i < len(sid_total):
@@ -205,8 +206,8 @@ async def update_all():
     if sid_iccids:
         await batch_insert(sid_iccids)
 
-    print(f"finish task, at {pendulum.now()} success：{len(sid_iccids)}, "
-          f"fail：{len(fail_sid)}")
+    logging.info(f"finish task, at {pendulum.now()} success：" \
+                 f"{len(sid_iccids)}, fail：{len(fail_sid)}")
 
     # if fail_sid:
     #     sid_iccids, fail_two, tmp = [], set(), []