if len(cities) == 1000:
    es.bulk_index(es_index, 'city', cities, id_field='id')
cities = []
if len(cities) > 0:
    es.bulk_index(es_index, 'city', cities, id_field='id')
Массовая индексация elasticsearch с использованием python