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实现提取某个索引中某个时间段的数据方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。