今天小编就为大家分享一篇python 实现提取某个索引中某个时间段的数据方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
如下所示：
from elasticsearch import Elasticsearch import datetime import time import dateutil.parser class App(object): def __init__(self): pass def _es_conn(self): es = Elasticsearch() return es def get_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-dd HH: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"<b style="color:transparent">来源gao@dai!ma.com搞$代^码网</b>, "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('20180330 09:53:00','%Y%m%d %H:%M:%S') end = datetime.datetime.strptime('20180330 15:44:00','%Y%m%d %H:%M:%S') app = App() app.get_data(day,start,end)
以上这篇python 实现提取某个索引中某个时间段的数据方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持gaodaima搞代码网。
以上就是python 实现提取某个索引中某个时间段的数据方法的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：python 实现提取某个索引中某个时间段的数据方法
转载请注明原文链接：python 实现提取某个索引中某个时间段的数据方法
