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