github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

fix: 修复存在无效 es 时获取终端配置失败的问题

pull/9910/head
Bai 2023-03-09 17:07:04 +08:00 committed by Jiangjie.Bai
parent dfbe8c0bc4
commit 266f5e9350
1 changed files with 20 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
apps/common/plugins/es.py
View File

@ -114,26 +114,28 @@ class ES(object):
self._ensure_index_exists() self._ensure_index_exists()
def _ensure_index_exists(self): def _ensure_index_exists(self):
info = self.es.info()
version = info['version']['number'].split('.')[0]
if version == '6':
mappings = {'mappings': {'data': {'properties': self.properties}}}
else:
mappings = {'mappings': {'properties': self.properties}}
if self.is_index_by_date:
mappings['aliases'] = {
self.query_index: {}
}
try: try:
self.es.indices.create(self.index, body=mappings) info = self.es.info()
return version = info['version']['number'].split('.')[0]
except RequestError as e: if version == '6':
if e.error == 'resource_already_exists_exception': mappings = {'mappings': {'data': {'properties': self.properties}}}
logger.warning(e)
else: else:
logger.exception(e) mappings = {'mappings': {'properties': self.properties}}
if self.is_index_by_date:
mappings['aliases'] = {
self.query_index: {}
}
try:
self.es.indices.create(self.index, body=mappings)
except RequestError as e:
if e.error == 'resource_already_exists_exception':
logger.warning(e)
else:
logger.exception(e)
except Exception as e:
logger.error(e, exc_info=True)
def make_data(self, data): def make_data(self, data):
return [] return []