From 4285ec386bb5104d8029e52ac8299f4209ae7aee Mon Sep 17 00:00:00 2001 From: junjun Date: Fri, 19 Sep 2025 11:37:32 +0800 Subject: [PATCH] refactor: Optimization Elasticsearch error prompt --- backend/apps/db/es_engine.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/backend/apps/db/es_engine.py b/backend/apps/db/es_engine.py index 75e7980b..f8cf1f2f 100644 --- a/backend/apps/db/es_engine.py +++ b/backend/apps/db/es_engine.py @@ -8,6 +8,7 @@ import requests from elasticsearch import Elasticsearch from apps.datasource.models.datasource import DatasourceConf +from common.error import SingleMessageError def get_es_connect(conf: DatasourceConf): @@ -109,6 +110,8 @@ def get_es_data_by_http(conf: DatasourceConf, sql: str): # print(response.json()) res = response.json() + if res.get('error'): + raise SingleMessageError(json.dumps(res)) fields = res.get('columns') result = res.get('rows') return result, fields