From cd733fb0573956139a89f03199e6bc5851d96890 Mon Sep 17 00:00:00 2001 From: H Vs Date: Fri, 14 Mar 2025 11:25:33 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/app.py b/app.py index 3b54afb..6060590 100644 --- a/app.py +++ b/app.py @@ -255,6 +255,10 @@ def scan_wx_login_info(): print("重连失败，重新登录...") print("发送离线消息到kafka") redis_helper.redis_helper.update_hash_field(k,'status',0) + + # 推送到kafka + input_message=utils.wx_offline_message(app_id,wxid) + kafka_helper.kafka_client.produce_message(input_message) time.sleep(3)