更新代码

data_sync/utils.py

@@ -188,6 +188,6 @@ def get_es_instance():
         'sniff_on_start': False,
         'sniff_on_connection_fail': False,
     }
-    new_hosts = settings.ES_HOSTS
+    new_hosts = settings.ES7_HOSTS
     __es_instance = Elasticsearch(hosts=new_hosts, **init_args)
     return __es_instance

qa/models/toutiao.py

@@ -64,7 +64,7 @@ def get_es(es_hosts_config=None):
         'sniff_on_start': False,
         'sniff_on_connection_fail': False,
     }
-    new_hosts = settings.ES_V2_HOSTS if not es_hosts_config else es_hosts_config
+    new_hosts = settings.ES7_HOSTS if not es_hosts_config else es_hosts_config
     new_es = Es(hosts=new_hosts, **init_args)
     return new_es
 
@@ -84,7 +84,7 @@ def es_query(doc, body, offset, size, es=None):
         es = get_es()
 
     index = es_index_adapt(
-        index_prefix=settings.ES_INDEX_PREFIX,
+        index_prefix=settings.ES7_HOSTS,
         doc_type=doc,
         rw='read'
     )
@@ -92,7 +92,7 @@ def es_query(doc, body, offset, size, es=None):
     res = es.search(
         index=index,
         doc_type=doc,
-        timeout=settings.ES_SEARCH_TIMEOUT,
+        timeout=settings.ES7_HOSTS,
         body=body,
         from_=offset,
         size=size)