1. 执行删除并获取任务 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']

2. 通过查询任务状态来检查删除是否已完成：

response = es.tasks.get(
  task_id=taskid,
  wait_for_completion=True
)

if response['completed']:
  # 删除已完成
  # 在此继续代码

3. 将删除操作设置为同步模式并在删除完成前等待：

response = es.delete_by_query(
  index='my-index',
  body={
    "query": {
      "match_all": {}
    }
  },
  wait_for_completion=True
)

# 删除已完成，可以继续代码