Skip to content

Commit 676edeb

Browse files
committed
feat: json parse
1 parent ecb7df9 commit 676edeb

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

backend/apps/chat/api/chat.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
import json
2+
import orjson
23
import traceback
34
from typing import List
45

@@ -138,7 +139,7 @@ def run_task():
138139
# execute sql
139140
result = llm_service.execute_sql(sql=sql)
140141
llm_service.save_sql_data(session=session, data_obj=result)
141-
yield json.dumps({'content': json.dumps(result, ensure_ascii=False), 'type': 'sql-data'}) + '\n\n'
142+
yield json.dumps({'content': orjson.dumps(result).decode(), 'type': 'sql-data'}) + '\n\n'
142143

143144
# generate chart
144145
chart_res = llm_service.generate_chart(session=session)

backend/apps/chat/task/llm.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
import json
2+
import orjson
23
import logging
34
import warnings
45
from typing import Any, List, Union, Dict
@@ -218,7 +219,7 @@ def save_error(self, session: SessionDep, message: str):
218219

219220
def save_sql_data(self, session: SessionDep, data_obj: Dict[str, Any]):
220221
return save_sql_exec_data(session=session, record_id=self.record.id,
221-
data=json.dumps(data_obj, ensure_ascii=False))
222+
data=orjson.dumps(data_obj).decode())
222223

223224
def finish(self, session: SessionDep):
224225
return finish_record(session=session, record_id=self.record.id)

0 commit comments

Comments
 (0)