Commit 41afc9ec authored by lixiaofang's avatar lixiaofang

add

parent 7a66552d
...@@ -134,6 +134,7 @@ ...@@ -134,6 +134,7 @@
<component name="FindInProjectRecents"> <component name="FindInProjectRecents">
<findStrings> <findStrings>
<find>/da</find> <find>/da</find>
<find>existing</find>
</findStrings> </findStrings>
</component> </component>
<component name="Git.Settings"> <component name="Git.Settings">
......
...@@ -149,7 +149,7 @@ class ESPerform(object): ...@@ -149,7 +149,7 @@ class ESPerform(object):
def es_helpers_bulk(cls, es_cli, data_list, sub_index_name, auto_create_index=False, doc_type="_doc"): def es_helpers_bulk(cls, es_cli, data_list, sub_index_name, auto_create_index=False, doc_type="_doc"):
try: try:
assert (es_cli is not None) assert (es_cli is not None)
official_index_name = sub_index_name
if sub_index_name != "mv-alpha-tag-test-190711901": if sub_index_name != "mv-alpha-tag-test-190711901":
official_index_name = cls.get_official_index_name(sub_index_name, "write") official_index_name = cls.get_official_index_name(sub_index_name, "write")
...@@ -189,8 +189,10 @@ class ESPerform(object): ...@@ -189,8 +189,10 @@ class ESPerform(object):
batch_search=False, routing=None): batch_search=False, routing=None):
try: try:
assert (es_cli is not None) assert (es_cli is not None)
official_index_name = sub_index_name
if sub_index_name != "mv-alpha-tag-test-190711901":
official_index_name = cls.get_official_index_name(sub_index_name, "read")
official_index_name = cls.get_official_index_name(sub_index_name, "read")
index_exists = es_cli.indices.exists(official_index_name) index_exists = es_cli.indices.exists(official_index_name)
if not index_exists: if not index_exists:
if not auto_create_index: if not auto_create_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