elasticsearch helpers.scan

elasticsearch_helpers_scan.py

from elasticsearch import Elasticsearch
from elasticsearch import helpers

start_time = "Some Date"
end_time = "Some Date"
parameter = ""
query = {"query": {"bool":
                 {"must": [
                         {"match": {"parameter": parameter}},
                         {"range": {"timestamp": {"gte": start_time, "lte": end_time}}}
                      ]
                   }
                 }      
res = helpers.scan(self.es,
                    query=query,
                    index="index_name", scroll=u'480m'
                )
for hit in res:
      parameter1 = hit["_source"]["parameter1"]
      parameter2 = hit["_source"]["paramater2"]
      # ...