update

tasks/crawler_week_report.py

@@ -54,7 +54,7 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 
 
 
-es_framework = Elasticsearch(hosts='172.16.32.37', port=9200)
+
 rds = redis.StrictRedis(host='172.16.40.164', port=6379, db=19, password='ReDis!GmTx*0aN12')
 
 conn_mimas = pymysql.connect(host='172.16.30.138', port=3306, user='mimas', passwd='GJL3UJe1Ck9ggL6aKnZCq4cRvM',
@@ -261,6 +261,7 @@ class WritrExcel():
 
 
 def get_search_keywrod_dict():
+    es_framework = Elasticsearch(hosts='172.16.32.37', port=9200)
     search_body = {
         "query": {
             "bool": {
@@ -278,6 +279,7 @@ def get_search_keywrod_dict():
 
 
 def get_hot_crawler_data_count(index, start_ts):
+    es_framework = Elasticsearch(hosts='172.16.32.37', port=9200)
     search_body = {
         "query": {
             "bool": {