es_src = Elasticsearch(['host'])
es_des = Elasticsearch(['host'])
body = {'query': {'term': {'year': '2004'}}}
helpers.reindex(es_src, 'src_index_name', 'des_index_name', target_client=
    es_des, query=body)
Reindexing Elastic search via Bulk API, scan and scroll