更改es查询语法

utils/es_api.py

 #!/usr/bin/env python
 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 # -*- coding:utf-8 -*-
-
+import requests
 from datetime import datetime, timedelta
 from datetime import datetime, timedelta
 
 
-from elasticsearch import Elasticsearch
+# from elasticsearch import Elasticsearch
 
 
-ichunt_elk = Elasticsearch(host="172.18.137.50", port=9200, timeout=20)
+# ichunt_elk = Elasticsearch(host="172.18.137.50", port=9200, timeout=20)
 task_mapping = {
 task_mapping = {
     'arg': 'arrow sku更新',
     'arg': 'arrow sku更新',
     'arc': 'arrow新品采集',
     'arc': 'arrow新品采集',
@@ -120,8 +120,13 @@ def get_task_error_rate(time_range=30, error_rate=30):
             }
             }
         }
         }
     }
     }
-    response = ichunt_elk.search(index=index, doc_type='doc', body=query)
-    buckets = response['aggregations']['taskCodes']['buckets']
+    # response = ichunt_elk.search(index=index, doc_type='doc', body=query)
+    # buckets = response['aggregations']['taskCodes']['buckets']
+    url = "http://172.18.137.50:9200/" + index + "/_search"
+    res = requests.post(url, json=query)
+
+    # value = response['aggregations']['avgFailRate']['value']
+    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