Remove all records of specified _type from ElasticSearch

drop_all_doc_types.py

def drop_all_doc_types(es: Elasticsearch, type_=ES_DOC_TYPE):
    while es.count()["count"] > 0:
        r = es.search(
            index=ES_INDEX,
            doc_type=type_,
            filter_path=["hits.hits._id"],
            body={"query": {"match_all": {}}},
            size=10000,
        )
        ids = [x["_id"] for x in r["hits"]["hits"]] if r else []
        if not ids:
            return
        bulk_body = [
            '{{"delete": {{"_index": "{}", "_type": "{}", "_id": "{}"}}}}'.format(
                ES_INDEX, type_, x
            )
            for x in ids
        ]
        es.bulk("\n".join(bulk_body))