修改mapping

trans2es/management/commands/trans2es_mapping2es.py

@@ -56,7 +56,6 @@ class Command(BaseCommand):
         ]):
             raise CommandError(
                 'unknown type name, type must be one of [topic, tag, itemwiki, diary, service, doctor, user, _all]，ItemWiki,newwiki')
-
         if options['type'] in ['service', 'sku']:
             es = get_talos_es()
         else:
@@ -115,8 +114,10 @@ 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)
+
         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":
@@ -125,6 +126,5 @@ 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

@@ -40,7 +40,7 @@ def create_index(es, index_prefix, doc_type):
     )
     if not cl.exists(index=index):
         cl.create(index=index)
-        init_alias(es, index_prefix, doc_type)
+        init_alias(es, index_prefix, "_doc")
         return True
     else:
         return False
@@ -111,9 +111,7 @@ 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)
-    print(mapping_copy)
-    print(index)
-    print(doc_type)
+
     return cl.put_mapping(index=index, doc_type=doc_type, body=mapping_copy)
 
 
@@ -154,7 +152,7 @@ def init_alias(es, index_prefix, doc_type):
     cl.update_aliases(body=content)
 
 
-def update_max_min(key, score):
+def update_max_min(key,score):
     try:
         redis_client = redis.StrictRedis.from_url(settings.DORIS_URL)
         data_dcit = redis_client.hgetall(key)
@@ -170,6 +168,6 @@ def update_max_min(key, score):
                 data_dcit[b"min"] = score
         else:
             data_dcit[b"min"] = score
-        redis_client.hmset(key, data_dcit)
+        redis_client.hmset(key,data_dcit)
     except:
        logging_exception()