From 7d7da9bf989bfb15fc1a7b887eb4831c4bcfe46c Mon Sep 17 00:00:00 2001
From: xinwen <coderWen@126.com>
Date: Tue, 17 Aug 2021 11:20:11 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E6=B7=BB=E5=8A=A0=E6=96=B0=E7=9A=84=20e?=
 =?UTF-8?q?s=20=E6=97=B6=E5=88=9B=E5=BB=BA=E7=B4=A2=E5=BC=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/terminal/backends/command/es.py | 19 ++++++++++++++++---
 1 file changed, 16 insertions(+), 3 deletions(-)

diff --git a/apps/terminal/backends/command/es.py b/apps/terminal/backends/command/es.py
index 1248f2a32..72a39d13c 100644
--- a/apps/terminal/backends/command/es.py
+++ b/apps/terminal/backends/command/es.py
@@ -76,10 +76,23 @@ class CommandStore():
         self._ensure_index_exists()
 
     def _ensure_index_exists(self):
+        mappings = {
+            "mappings": {
+                "properties": {
+                    "session": {
+                        "type": "keyword"
+                    },
+                    "org_id": {
+                        "type": "keyword"
+                    }
+                }
+            }
+        }
+
         try:
-            self.es.indices.create(self.index)
-        except RequestError:
-            pass
+            self.es.indices.create(self.index, body=mappings)
+        except RequestError as e:
+            logger.exception(e)
 
     @staticmethod
     def make_data(command):