Commit d4e06a85 authored by 李小芳's avatar 李小芳

修改mapping

parent 72cf6c00
...@@ -74,7 +74,7 @@ def load_mapping(doc_type): ...@@ -74,7 +74,7 @@ def load_mapping(doc_type):
def put_mapping(es, index_prefix, doc_type, mapping, delete=False): def put_mapping(es, index_prefix, doc_type, mapping, delete=False):
print(es) doc_type = "_doc"
cl = es.indices cl = es.indices
index = es_index_adapt( index = es_index_adapt(
index_prefix=index_prefix, index_prefix=index_prefix,
...@@ -112,8 +112,7 @@ def put_mapping(es, index_prefix, doc_type, mapping, delete=False): ...@@ -112,8 +112,7 @@ def put_mapping(es, index_prefix, doc_type, mapping, delete=False):
import copy import copy
mapping_copy = copy.deepcopy(mapping) mapping_copy = copy.deepcopy(mapping)
mapping_copy = _mapping_modify(es, doc_type, mapping_copy) mapping_copy = _mapping_modify(es, doc_type, mapping_copy)
# return cl.put_mapping(index=index, doc_type="_doc", body=mapping_copy) return cl.put_mapping(index=index, doc_type=doc_type, body=mapping_copy)
return cl.put_mapping(index=index, body=mapping_copy)
def alias_shift(es, alias, old_index, new_index): def alias_shift(es, alias, old_index, new_index):
......
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