Elasticsearch _update_by_query：搜索等待方案及未完成时行为咨询

一、搜索等待_update_by_query完成的替代方案 #

由于_update_by_query不支持refresh=wait_for参数，无法让后续搜索自动等待更新完成，可通过以下几种方式实现类似效果：

• 索引别名切换策略
  预先创建业务使用的索引别名，指向当前提供服务的索引。执行_update_by_query时，在临时副本索引上完成更新操作，待任务完全结束后，将别名切换为指向更新后的临时索引，同时删除旧索引。所有搜索请求通过别名访问，只会获取到更新完成后的完整数据，适合大规模数据更新场景。

• 任务状态校验+搜索阻塞等待
  发起_update_by_query请求时添加wait_for_completion=false参数，获取返回的任务ID（task字段）。后续搜索进程执行搜索前，先调用GET _tasks/{task_id}接口查询任务状态：

  • 若任务状态为completed，正常执行搜索；
  • 若任务未完成，则等待一段时间后重试，直到任务完成再执行搜索。
    示例查询任务状态命令：

  GET _tasks/oEc1eHaQQMqyF9X77Q0ZAw:12345
  

• 基于文档版本的过滤搜索
  若更新逻辑涉及文档版本号变更（_update_by_query默认递增文档版本），可在搜索请求中添加版本范围过滤条件，仅查询版本号大于更新起始版本的文档。该方案需提前记录更新前的最大版本号，仅适用于对版本有明确依赖的场景。

二、_update_by_query未完成时执行搜索的行为 #

当_update_by_query正在执行时发起搜索请求，会出现以下情况：

1. 部分更新结果可见：_update_by_query默认按批次（默认1000条/批次）处理文档，每批次更新完成后提交事务。已提交批次的文档更新，会在Elasticsearch默认刷新间隔（默认1秒）后被搜索到；若搜索时指定refresh=true参数，可立即看到已提交批次的更新结果。
2. 数据不一致性：搜索结果会混合更新完成和未完成的文档，部分文档为更新后的状态，部分仍是原状态，无法保证数据原子性一致。
3. refresh参数的局限性：_update_by_query的refresh参数仅支持true或false（默认false）。设置refresh=true时，只会在整个任务完成后强制刷新所有分片，不会在执行过程中实时刷新，因此无法通过该参数让搜索等待更新完成。

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