ElasticSearch: Alle Dokumente im Index iterieren / scrollen

def es_iterate_all_documents(es, index, pagesize=250, scroll_timeout="1m", **kwargs):
    """
    Hilfsfunktion, um ALLE Werte aus einem einzelnen Index zu iterieren
    Yields all the documents.
    """
    is_first = True
    while True:
        # Scrollen zum nächsten
        if is_first: # Scroll initialisieren
            result = es.search(index=index, scroll="1m", **kwargs, body={
                "size": pagesize
            })
            is_first = False
        else:
            result = es.scroll(body={
                "scroll_id": scroll_id,
                "scroll": scroll_timeout
            })
        scroll_id = result["_scroll_id"]
        hits = result["hits"]["hits"]
        # Stoppen, wenn keine Docs mehr da sind
        if not hits:
            break
        # Jeden Eintrag zurückgeben
        yield from (hit['_source'] for hit in hits)

es = Elasticsearch([{"host": "localhost"}])

for entry in es_iterate_all_documents(es, 'my_index'):
    print(entry) # Gibt das Dokument aus, wie es in der DB gespeichert ist