yumoqing/kboss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source 
Reviewed-on: #40
This commit is contained in:
charles 2025-11-20 17:53:09 +08:00
commit 9593408770
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
b/baiduc/baidu_sms_kafka_consumer.dspy
View File

@ -39,13 +39,13 @@ async def baidu_sms_kafka_consumer(ns={}):
pass pass
total_count = 0 total_count = 0
for i in range(1): for i in range(10):
# if i == 0: # if i == 0:
# # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS # # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS
# with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f: # 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") # f.write(f"轮询开始时间：{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
msg = consumer.poll(1) # 单次轮询获取消息 msg = consumer.poll(0.01) # 单次轮询获取消息
if msg is None: if msg is None:
if i == 10: if i == 10: