修改mapping

trans2es/utils/es.py

@@ -113,6 +113,8 @@ def put_mapping(es, index_prefix, doc_type, mapping, delete=False):
     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)
 
 
@@ -153,7 +155,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)
@@ -169,6 +171,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()
+        logging_exception()