Update app.py

app.py

@@ -148,7 +148,6 @@ def messages():
                     text = json.loads(data['text'])
                     chunk = text['chunks'][-1] if text['chunks'] else None
                     if chunk:
-                        chunk = json.loads(f'"{chunk}"')  # 解码 Unicode 转义序列
                         response_text.append(chunk)
 
             def on_query_complete(data):
@@ -199,7 +198,7 @@ def messages():
                 "delta": {"stop_reason": "end_turn", "stop_sequence": None},
                 "usage": {"output_tokens": len(''.join(response_text))},
             })
-            yield create_event("message_stop", {"type": "message_stop"})  # 添加 message_stop 事件
+            yield create_event("message_stop", {"type": "message_stop"})
             log_request(request.remote_addr, request.path, 200)
 
         return Response(generate(), content_type='text/event-stream')
@@ -222,7 +221,7 @@ def server_error(error):
 
 def create_event(event, data):
     if isinstance(data, dict):
-        data = json.dumps(data)
+        data = json.dumps(data, ensure_ascii=False)  # 确保中文不会被转义
     return f"event: {event}\ndata: {data}\n\n"
 
 if __name__ == '__main__':