From 69bc20698cbffc5513bc498c6562f2dea6ac5a7d Mon Sep 17 00:00:00 2001 From: junjun Date: Tue, 16 Sep 2025 14:53:27 +0800 Subject: [PATCH] feat: support Elasticsearch datasource #108 --- backend/apps/db/db.py | 2 +- backend/apps/db/es_engine.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/apps/db/db.py b/backend/apps/db/db.py index 495a88ff..a1da1492 100644 --- a/backend/apps/db/db.py +++ b/backend/apps/db/db.py @@ -434,4 +434,4 @@ def exec_sql(ds: CoreDatasource | AssistantOutDsSchema, sql: str, origin_column= return {"fields": columns, "data": result_list, "sql": bytes.decode(base64.b64encode(bytes(sql, 'utf-8')))} except Exception as ex: - raise ParseSQLResultError(str(ex)) + raise Exception(str(ex)) diff --git a/backend/apps/db/es_engine.py b/backend/apps/db/es_engine.py index 6f7a1030..05c5797b 100644 --- a/backend/apps/db/es_engine.py +++ b/backend/apps/db/es_engine.py @@ -63,7 +63,7 @@ def get_es_fields(conf: DatasourceConf, table_name: str): def get_es_data(conf: DatasourceConf, sql: str, table_name: str): r = requests.post(f"{conf.host}/_sql/translate", json={"query": sql}) if r.json().get('error'): - raise BaseException(f'{json.dumps(r.json())}') + print(json.dumps(r.json())) es_client = get_es_connect(conf) response = es_client.search(