1 changed files with 1 additions and 1 deletions
+ 1
- 1
app/endpoints/pipeline_endpoint.py
View File
| @@ -1270,7 +1270,7 @@ async def handle_add_friend_notice_async(request: Request,token_id,app_id, wxid, | |||||
| # 发送到kafka | # 发送到kafka | ||||
| input_wx_content_dialogue_message=[{"type": "text", "text": reply_content}] | input_wx_content_dialogue_message=[{"type": "text", "text": reply_content}] | ||||
| input_message=dialogue_message(wxid,to_contact_wxid,input_wx_content_dialogue_message,True) | input_message=dialogue_message(wxid,to_contact_wxid,input_wx_content_dialogue_message,True) | ||||
| request.app.state.kafka_service.send_message_async(input_message) | |||||
| await request.app.state.kafka_service.send_message_async(input_message) | |||||
| logger.info("发送对话 %s",input_message) | logger.info("发送对话 %s",input_message) | ||||
| else: | else: | ||||
Loading…