import requests
import datetime
import time
url_search = """http://xxx:9200/cdblog-stat-error/_search"""
fmb_time = ((datetime.datetime.now()-datetime.timedelta(minutes=20)).strftime("%Y-%m-%dT%H:%M:%S+08:00"))
now_time = (datetime.datetime.now()).strftime("%Y-%m-%dT%H:%M:%S+08:00")
query = json.dumps({"query": {"bool": {"filter": [{"term": {"cdblog.alarm_words": "terribly wrong"}},{"range": {"@timestamp": {"gte": fmb_time,"lt": now_time}}}]}},"_source": {"includes": ["instinfo.instid","instinfo.ip","instinfo.port","instinfo.insttype","cdblog.timestamp"]}})
try:
headers = {"Content-Type": 'application/json'}
user="elastic"
password="xxx"
response = requests.get(url_search, data=query,headers=headers,auth=(user,password))
results = json.loads(response.text)
except exceptions.Timeout as e:
print('请求超时：'+str(e.message) + url_search)
except exceptions.HTTPError as e:
print('http请求错误:'+str(e.message) + url_search)
