如何向Elasticsearch各路由/分片发送_search查询及批量删除指定文档

我之前处理过类似的Elasticsearch强制路由场景，给你分享下可行的解决方案：

一、如何向每个路由/分片发送_search查询 #

由于你的环境强制要求携带routing参数才能执行查询，且索引有64个主分片，我们可以利用ES默认的路由哈希规则来精准覆盖所有分片：

ES默认使用murmur3_hash(routing值) % 主分片数来决定路由对应的分片，所以当分片数为64时，用0~63作为路由值，每个值会精准映射到对应编号的分片（比如routing=0对应分片0，routing=1对应分片1，以此类推）。

具体步骤：

• 遍历路由值从0到63
• 对每个路由值发起查询请求，示例如下：

GET /<你的索引名>/<你的类型名>/_search?routing=0
{
  "query": {
    "exists": {
      "field": "<你要匹配的特定字段>"
    }
  },
  "size": 1000  # 按需调整每页返回数量
}

• 如果单页返回的结果不够，用scrollAPI进行分页查询，避免漏取文档：

# 初始化scroll
GET /<你的索引名>/<你的类型名>/_search?routing=0&scroll=1m
{
  "query": {"exists": {"field": "<特定字段>"}},
  "size": 1000
}

# 后续用scroll_id获取下一页
GET /_search/scroll
{
  "scroll": "1m",
  "scroll_id": "<上一步返回的scroll_id>"
}

这样遍历完64个路由值，就能覆盖所有分片上的目标文档。

二、在强制路由环境下批量删除指定文档 #

你原本的“先查后删”思路是可行的，但需要结合路由规则调整，这里有两种方案：

方案1：使用Bulk API批量删除（无需额外插件） #

1. 按照上面的方法，遍历每个路由值（0~63），用scroll获取该分片上所有符合条件的文档的_id
2. 对每个路由值对应的文档列表，构造Bulk删除请求，必须携带对应路由值，示例：

POST /_bulk?routing=0
{"delete": {"_index": "<你的索引名>", "_type": "<你的类型名>", "_id": "<文档ID1>"}}
{"delete": {"_index": "<你的索引名>", "_type": "<你的类型名>", "_id": "<文档ID2>"}}
# 可批量添加更多delete操作，建议每个Bulk请求控制在几MB以内

3. 依次对64个路由值执行上述操作，完成全量删除。

方案2：使用Delete By Query（需安装插件，更高效） #

如果你的ES 2.x环境安装了delete-by-query插件（ES 2.x默认不包含，需要手动安装），可以直接针对每个路由值执行删除请求，无需先查询文档ID：

POST /<你的索引名>/<你的类型名>/_delete_by_query?routing=0
{
  "query": {
    "exists": {
      "field": "<你要匹配的特定字段>"
    }
  }
}

同样遍历0~63的路由值，每个路由值执行一次上述请求即可。

关键注意事项 #

• 所有操作必须携带对应路由值，否则会因环境限制被拒绝，或找不到目标文档
• 避免一次性发起过多请求，建议串行遍历路由值，或控制并发数，防止ES集群过载
• 如果文档量极大，建议分批次执行，配合scroll的超时时间调整，避免查询超时

内容的提问来源于stack exchange，提问作者vuryss