update

crawler_process.py

@@ -67,10 +67,7 @@ def get_error_ratio(task_code, time_range=30):
     res = requests.post(url,json=query)
     res = requests.post(url,json=query)
 
 
     # value = response['aggregations']['avgFailRate']['value']
     # value = response['aggregations']['avgFailRate']['value']
-    print("-_________")
-    print(res.json())
-    print(task_code)
-    value = res.json()['aggregations']['avgFailRate']['value']  if res.status_code!=200 else 0.0
+    value = res.json()['aggregations']['avgFailRate']['value']  if res.status_code==200 else 0.0
     return round(value, 3)
     return round(value, 3)
 
 
 
 
@@ -96,7 +93,6 @@ def get_crawler_process_info():
         info_dict['run_time'] = round(sum(info['cpu_times']), 3)
         info_dict['run_time'] = round(sum(info['cpu_times']), 3)
         info_dict['remain_task'], info_dict['remain_wrong_task'] = get_process_task(info_dict['task_code'])
         info_dict['remain_task'], info_dict['remain_wrong_task'] = get_process_task(info_dict['task_code'])
         info_dict['wrong_radio'] = get_error_ratio(info_dict['task_code'])
         info_dict['wrong_radio'] = get_error_ratio(info_dict['task_code'])
-        print(info_dict['task_code'],info_dict['wrong_radio'])
         process[info_dict['unique_code']] = info_dict
         process[info_dict['unique_code']] = info_dict
     return process
     return process
 
 

utils/es_api.py

@@ -126,7 +126,7 @@ def get_task_error_rate(time_range=30, error_rate=30):
     res = requests.post(url, json=query)
     res = requests.post(url, json=query)
 
 
     # value = response['aggregations']['avgFailRate']['value']
     # value = response['aggregations']['avgFailRate']['value']
-    buckets = res.json()['aggregations']['avgFailRate']['value'] if res.status_code != 200 and res.json()['aggregations']['taskCodes']['buckets'] else ""
+    buckets = res.json()['aggregations']['avgFailRate']['value'] if res.status_code == 200 and res.json()['aggregations']['taskCodes']['buckets'] else ""
     if buckets:
     if buckets:
         return gen_msg(time_range, buckets)
         return gen_msg(time_range, buckets)
     return
     return