如何在python 2.7中执行这个CURL来从Elasticsearch中删除文档？

Question

您好，我是python和elasticsearch的新手。我在本地设置了Elasticsearch，并向其中添加了数据。http://127.0.0.1:9200/index_data/type_data.

我想从type\u数据中删除一些\u id。假设要删除的\u id列表为x=['a'，'b'，'c.'d'。

curl-XDELETE“localhost:9200/index\u data/type\u data/a？漂亮的'

使用这个命令，我可以从elasticsearch中删除一个特定的\u id，但是如何使用python执行这个curl请求呢？

是否可以使用python删除整个type_data？

为什么此代码不起作用？

from elasticsearch import Elasticsearch 
es = Elasticsearch()
request_body = {
    "query": {
        "ids": {
            "values": ['a','b','c','d','e','f']
        }
    }
}
es.delete_by_query(index=es_index, body=request_body)

我使用的是Elasticsearch版本6.1.0。elasticsearch py版本5.4.0

请救救我！

Answer 1

如果有很多ID，请在python:Documentation中尝试并行\u批量删除：http://elasticsearch-py.readthedocs.io/en/master/helpers.html#elasticsearch.helpers.parallel_bulk

from elasticsearch import Elasticsearch
from elasticsearch import helpers

es = Elasticsearch()
index_name = es_index
doc_type = your_doc_type
ids = ['a','b','c','d','e','f']


def generate_actions(ids):
    for i in ids:
        yield {
            '_op_type': 'delete',
            '_index': index_name,
            '_type': doc_type,
            '_id': i
        }


for success, info in helpers.parallel_bulk(client=es, actions=generate_actions(ids), thread_count=4):
    if not success: 
        print('Doc failed', info)