Update app.py

app.py

@@ -42,45 +42,30 @@ def request_to_v2(message, cookie, user_id, channel_id,context=[]):
     post_msg_data = json.dumps(post_msg_data)
     print(post_msg_data)
 
-    try:
+     try:
         response = requests.post(post_msg_url, headers=headers, data=post_msg_data, verify=False, stream=False)
         print(response)
 
         print(response.status_code)
         print(response.request)
+        bots = ""
         for data in response.iter_lines():
             if data:
                 print(data)
+                bots = bots + data
 
-
-                # 将事件数据分割为多行
-                # event_data = line.decode('utf-8')
-                # print(event_data)
-                # encoding = chardet.detect(line)['encoding']
-                # print(chardet.detect(line))
-                # decoded_string = line.decode('hex')
-                # print(decoded_string)
-                # event_data = decoded_string.split('\n')
-                # for data in event_data:
-                #     if data:
-                #         print(data)
-        # response.close()
-        context += [response]
+        context += [bots]
         responses = [(u, b) for u, b in zip(context[::2], context[1::2])]
         return responses, context
 
     except BaseException as e:
         print("查询失败,正在重试")
         print(e)
-        for o in range(times):
-            try:
-                res = requests.post(post_msg_url, headers=headers, data=post_msg_data, verify=False, stream=True, allow_redirects=True)
-                if res.status_code == 200:
-                    break
-            except BaseException as e:
-                print("再次查询子域名失败", o)
-                print(e)
-        return False
+        response = e
+        context += [response]
+        responses = [(u, b) for u, b in zip(context[::2], context[1::2])]
+
+        return responses, context
 
 if __name__ == "__main__":