python 实现提取某个索引中某个时间段的数据方法
72 浏览量
2020-09-19
15:30:14
上传
评论 1
收藏 27KB PDF 举报
python 实现提取某个索引中某个时间段的数据方法实现提取某个索引中某个时间段的数据方法
今天小编就为大家分享一篇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",
"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 实现提取某个索引中某个时间段的数据方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也
希望大家多多支持我们。
资源评论
