调整

app/endpoints/pipeline_endpoint.py

@@ -81,9 +81,9 @@ async def handle_messages_async(request: Request,token_id,msg):
     msg_data=msg.get("Data")
     type_name =msg.get("TypeName")
 
-    app_id = msg.get("Appid")
-    from_wxid=msg_data["FromUserName"]["string"]
-    msg_content=msg_data["Content"]["string"]
+    # app_id = msg.get("Appid")
+    # from_wxid=msg_data["FromUserName"]["string"]
+    # msg_content=msg_data["Content"]["string"]
     wxid = msg.get("Wxid",'')
 
     match type_name: