From af535e7c712106289d2146b36ff7c2f3af15652c Mon Sep 17 00:00:00 2001 From: ping <1017253325@qq.com> Date: Fri, 21 Nov 2025 16:37:23 +0800 Subject: [PATCH] update --- kgadget/src/baidu_sms_kafka_consumer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/kgadget/src/baidu_sms_kafka_consumer.py b/kgadget/src/baidu_sms_kafka_consumer.py index f79c419..4acac5f 100644 --- a/kgadget/src/baidu_sms_kafka_consumer.py +++ b/kgadget/src/baidu_sms_kafka_consumer.py @@ -114,9 +114,9 @@ async def baidu_sms_kafka_consumer(ns={}): }) # 创建日志文件 - files = "baidu_kafka_msg.txt" - if not os.path.exists(filename): - with open(filename, 'w', encoding='utf-8') as f: # 'w' 模式会覆盖已有文件，但检查后使用是安全的 + filename = "baidu_kafka_msg.txt" + if not os.path.exists('/d/zhc/' + filename): + with open('/d/zhc/' + filename, 'w', encoding='utf-8') as f: # 'w' 模式会覆盖已有文件，但检查后使用是安全的 pass # 创建空文件 else: pass -- 2.34.1