Commit 153f4c3f authored by 李小芳's avatar 李小芳

修改mapping

parent cfb41a5e
...@@ -53,9 +53,5 @@ ...@@ -53,9 +53,5 @@
"type": "boolean" "type": "boolean"
} }
} }
},
"aliases": {
"gm-dbmw-group-read": {},
"gm-dbmw-group-write": {}
} }
} }
...@@ -40,7 +40,7 @@ def create_index(es, index_prefix, doc_type): ...@@ -40,7 +40,7 @@ def create_index(es, index_prefix, doc_type):
) )
if not cl.exists(index=index): if not cl.exists(index=index):
cl.create(index=index) cl.create(index=index)
init_alias(es, index_prefix, "_doc") init_alias(es, index_prefix, doc_type)
return True return True
else: else:
return False return False
...@@ -155,7 +155,7 @@ def init_alias(es, index_prefix, doc_type): ...@@ -155,7 +155,7 @@ def init_alias(es, index_prefix, doc_type):
cl.update_aliases(body=content) cl.update_aliases(body=content)
def update_max_min(key,score): def update_max_min(key, score):
try: try:
redis_client = redis.StrictRedis.from_url(settings.DORIS_URL) redis_client = redis.StrictRedis.from_url(settings.DORIS_URL)
data_dcit = redis_client.hgetall(key) data_dcit = redis_client.hgetall(key)
...@@ -171,6 +171,6 @@ def update_max_min(key,score): ...@@ -171,6 +171,6 @@ def update_max_min(key,score):
data_dcit[b"min"] = score data_dcit[b"min"] = score
else: else:
data_dcit[b"min"] = score data_dcit[b"min"] = score
redis_client.hmset(key,data_dcit) redis_client.hmset(key, data_dcit)
except: except:
logging_exception() logging_exception()
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment