修改mapping

trans2es/management/commands/trans2es_mapping2es.py

@@ -114,7 +114,7 @@ class Command(BaseCommand):
 
     def work(self, es, index_prefix, doc_type, delete=False):
         # create index if not exits
-        create_index(es=es, index_prefix=index_prefix, doc_type=doc_type)
+        create_index(es=es, index_prefix=index_prefix, doc_type="_doc")
 
         m = load_mapping(doc_type=doc_type)
 
@@ -127,5 +127,6 @@ class Command(BaseCommand):
             doc_type = "service"
         if doc_type == "service_ngram":
             doc_type = "service"
+
         print(put_mapping(es=es, index_prefix=index_prefix, doc_type=doc_type,
                           mapping=m, delete=delete))

trans2es/utils/es.py

@@ -74,9 +74,7 @@ def load_mapping(doc_type):
 
 
 def put_mapping(es, index_prefix, doc_type, mapping, delete=False):
-    doc_type = "_doc"
     cl = es.indices
-    print(cl)
     index = es_index_adapt(
         index_prefix=index_prefix,
         doc_type=doc_type,