From 47dd73eb4c8e2364bc8533c4d5dcaf5d5a46f61c Mon Sep 17 00:00:00 2001 From: "fangfang.dong" Date: Mon, 31 Jul 2023 14:54:35 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8Des7=E5=88=9B?= =?UTF-8?q?=E5=BB=BAindex=E7=9A=84=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/common/plugins/es.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apps/common/plugins/es.py b/apps/common/plugins/es.py index 27b97b3de..8438c43cc 100644 --- a/apps/common/plugins/es.py +++ b/apps/common/plugins/es.py @@ -131,7 +131,10 @@ class ES(object): } try: - self.es.indices.create(self.index, body=mappings) + if version == '6': + self.es.indices.create(self.index, body=mappings) + else: + self.es.indices.create(index=self.index, body=mappings) except RequestError as e: if e.error == 'resource_already_exists_exception': logger.warning(e) From 2ffadcb9bcd8d26f9a2728d5125669cc5bdab27e Mon Sep 17 00:00:00 2001 From: nut Date: Mon, 31 Jul 2023 17:53:08 +0800 Subject: [PATCH 2/2] Update es.py --- apps/common/plugins/es.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/apps/common/plugins/es.py b/apps/common/plugins/es.py index 8438c43cc..95f878263 100644 --- a/apps/common/plugins/es.py +++ b/apps/common/plugins/es.py @@ -131,10 +131,7 @@ class ES(object): } try: - if version == '6': - self.es.indices.create(self.index, body=mappings) - else: - self.es.indices.create(index=self.index, body=mappings) + self.es.indices.create(index=self.index, body=mappings) except RequestError as e: if e.error == 'resource_already_exists_exception': logger.warning(e)