修改mapping

trans2es/management/commands/trans2es_mapping2es.py

@@ -114,12 +114,9 @@ class Command(BaseCommand):
 
     def work(self, es, index_prefix, doc_type, delete=False):
         # create index if not exits
-        print(index_prefix)
         create_index(es=es, index_prefix=index_prefix, doc_type=doc_type)
-
         m = load_mapping(doc_type=doc_type)
 
-        # reset doc_type for experiment index
         if doc_type == "diary_norms_disable":
             doc_type = "diary"
         if doc_type == "sku_norms_disable":

trans2es/utils/es.py

@@ -111,7 +111,10 @@ def put_mapping(es, index_prefix, doc_type, mapping, delete=False):
     import copy
     mapping_copy = copy.deepcopy(mapping)
     mapping_copy = _mapping_modify(es, doc_type, mapping_copy)
-    return cl.put_mapping(index=index, doc_type="_doc", body=mapping_copy)
+    print(mapping_copy)
+    print(index)
+    print(doc_type)
+    return cl.put_mapping(index=index, doc_type=doc_type, body=mapping_copy)
 
 
 def alias_shift(es, alias, old_index, new_index):