python 实现提取某个索引中某个时间段的数据方法
如下所示：
fromelasticsearchimportElasticsearch
importdatetime
importtime
importdateutil.parser
classApp(object):
def__init__(self):
pass
def_es_conn(self):
es=Elasticsearch()
returnes
defget_data(self,day,start,end):
index_="gather-apk-20180330"
query_dsl={
"size":10000,
"query":{
"bool":{
"must":[
{"range":{
"receiveTime":{
"gte":start.strftime('%Y-%m-%d%H:%M:%S'),
"lte":end.strftime('%Y-%m-%d%H:%M:%S'),
"format":"yyyy-MM-ddHH:mm:SS",
"time_zone":"+08:00"
}
}},
{
"term":{
"obd2_localnet_id":{
"value":"101000"
}
}
},
{
"term":{
"obd2_substation_name":{
"value":"石羊支局"
}
}
}
]
}
},
"_source":["mac","iptvAccount","obd2_substation_name","obd2_company_name","obd2_grid_name",
"receiveTime","streamBreak","kaNum"]
}
rs=self._es_conn().search(
index=index_,
body=query_dsl
)
if__name__=='__main__':
day=datetime.datetime.now()
#the_day=day.strftime('%Y%m%d')
start=datetime.datetime.strptime('2018033009:53:00','%Y%m%d%H:%M:%S')
end=datetime.datetime.strptime('2018033015:44:00','%Y%m%d%H:%M:%S')
app=App()
app.get_data(day,start,end)
以上这篇python实现提取某个索引中某个时间段的数据方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。