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

Merge pull request 'updsate' (#46) from main into prod

Browse Source 
Reviewed-on: #46
This commit is contained in:
charles 2025-11-21 17:21:48 +08:00
commit 43131137b8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kgadget/src/baidu_sms_kafka_consumer.py
View File

@ -124,7 +124,7 @@ async def baidu_sms_kafka_consumer(ns={}):
# 订阅的主题名称 # 订阅的主题名称
consumer.subscribe(['kaiyuanyun_msg_topic']) consumer.subscribe(['kaiyuanyun_msg_topic'])
while True: while True:
msg = consumer.poll(2) # 单次轮询获取消息 msg = consumer.poll(1) # 单次轮询获取消息
if msg is None: if msg is None:
continue continue
@ -132,7 +132,7 @@ async def baidu_sms_kafka_consumer(ns={}):
pass pass
else: else:
try: try:
with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f: with open('/d/zhc/baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
f.write(f"{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}-{msg.value().decode('utf-8')}\n") f.write(f"{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}-{msg.value().decode('utf-8')}\n")
# print('Received message: {}'.format(msg.value().decode('utf-8'))) # print('Received message: {}'.format(msg.value().decode('utf-8')))