如下所示:
from elasticsearch import Elasticsearchimport datetimeimport timeimport dateutil.parserclass 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 實現提取某個索引中某個時間段的數據方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持武林站長站。
新聞熱點
疑難解答