update

task/daily_search_word_count_last_two_year.py

@@ -30,9 +30,16 @@ import datetime
 
 es = Elasticsearch([
     {
-        'host': '172.16.31.13',
-        'port': 9000,
-    }])
+        'host': '172.16.31.6',
+        'port': 9200,
+    }, {
+        'host': '172.16.31.16',
+        'port': 9200,
+    }, {
+        'host': '172.16.31.10',
+        'port': 9200,
+    }
+])
 
 
 def get_all_tag():
@@ -46,6 +53,7 @@ def get_all_tag():
     db.close()
     for res in result:
         res_dict[res[0]] = 1
+    print(res_dict)
     return res_dict
 
 
@@ -67,7 +75,7 @@ def from_es_get_service_num(query):
     }
 
     results = es.search(
-        index='gm-dbmw-service-write',
+        index='gm-dbmw-service',
         doc_type='service',
         timeout='10s',
         size=0,