- 执行删除并获取任务 ID:
from elasticsearch import Elasticsearch
es = Elasticsearch([''])
response = es.delete_by_query(
index='my-index',
body={
"query": {
"match_all": {}
}
},
wait_for_completion=False
)
taskid = response['task']
- 通过查询任务状态来检查删除是否已完成:
response = es.tasks.get(
task_id=taskid,
wait_for_completion=True
)
if response['completed']:
# 删除已完成
# 在此继续代码
- 将删除操作设置为同步模式并在删除完成前等待:
response = es.delete_by_query(
index='my-index',
body={
"query": {
"match_all": {}
}
},
wait_for_completion=True
)
# 删除已完成,可以继续代码