Merge pull request 'update' (#42) from main into prod

Reviewed-on: #42

kgadget/src/baidu_sms_kafka_consumer.py

@@ -125,10 +125,10 @@ async def baidu_sms_kafka_consumer(ns={}):
     # total_count = 0
     while True:
         i = 0
-        # if i == 0:
-        #     # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS
-        #     with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
-        #         f.write(f"轮询开始时间：{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
+        if i == 0:
+            # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS
+            with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
+                f.write(f"轮询开始时间：{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
         
         msg = consumer.poll(0.1)  # 单次轮询获取消息