可以使用 Elasticsearch 的 Python 客户端库 Elasticsearch-py 来实现读取 _id 列表并删除对应的数据。

以下是一个示例代码,假设需要删除 index 为 my_index,type 为 my_type 的数据,且要删除的数据的 _id 列表存储在一个名为 id_list 的列表中:

from elasticsearch import Elasticsearch

es = Elasticsearch()

index = "my_index"
doc_type = "my_type"
id_list = ["1", "2", "3"]

for doc_id in id_list:
    es.delete(index=index, doc_type=doc_type, id=doc_id)

代码中,首先创建了一个 Elasticsearch 实例,然后指定了要删除的 index 和 type,以及要删除的 _id 列表 id_list。接着使用 for 循环遍历 id_list,对于每个 _id,使用 Elasticsearch 的 delete 方法从 Elasticsearch 中删除对应的数据。

需要注意的是,如果要删除的数据不存在,delete 方法会抛出异常,需要在代码中进行异常处理

使用python 读取_id列表删除es中的数据

原文地址: https://www.cveoy.top/t/topic/fgZz 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录