1 changed files with 4 additions and 0 deletions
+ 4
- 0
app.py
View File
| @@ -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) | |||
Loading…