Elasticsearch 6.2与PHP客户端6.0：使用_update_by_query更新字段的问题

嘿，刚好我之前在ES 6.x版本里处理过类似的批量更新需求，给你说说怎么用_update_by_query搞定这个问题，完全不用提前获取所有文档ID～

核心思路 #

_update_by_query就是专门为批量更新符合查询条件的文档设计的API——它会先执行查询找到目标文档，再对每个匹配的文档执行更新逻辑，完美解决你需要逐个获取_id的痛点。

原生API示例（curl） #

先给你看个curl版本的请求，方便理解底层逻辑：

POST test/_update_by_query
{
  "query": {
    "term": {
      "userid": 123
    }
  },
  "script": {
    "source": "ctx._source.userid = 987",
    "lang": "painless"
  }
}

• query部分：用term查询匹配所有userid等于123的文档（如果你的userid是字符串类型，记得把123改成"123"）
• script部分：用ES默认支持的painless脚本，把当前文档的userid字段改成987，ctx._source代表当前文档的源数据

对应elasticsearch-php 6.0客户端的代码实现 #

因为你用的是6.0版本的PHP客户端，写法要对应这个版本的API：

<?php
require 'vendor/autoload.php';

use Elasticsearch\ClientBuilder;

// 初始化客户端（如果需要指定ES节点，可在create()后加->setHosts(['http://your-es-host:9200'])）
$client = ClientBuilder::create()->build();

$updateParams = [
    'index' => 'test', // 替换成你的索引名
    'body' => [
        'query' => [
            'term' => [
                'userid' => 123 // 匹配条件
            ]
        ],
        'script' => [
            'source' => 'ctx._source.userid = 987', // 更新逻辑
            'lang' => 'painless'
        ]
    ]
];

// 执行批量更新
$updateResponse = $client->updateByQuery($updateParams);

// 打印响应结果查看更新详情，比如成功更新的文档数、耗时等
print_r($updateResponse);
?>

实用注意事项 #

• 版本冲突处理：如果更新过程中有其他操作修改了匹配的文档，会触发版本冲突。如果想忽略冲突继续更新，可以在参数里加上'conflicts' => 'proceed'：

  $updateParams = [
      'index' => 'test',
      'conflicts' => 'proceed', // 忽略冲突
      'body' => [/* ... 其他配置 ... */]
  ];
  

• 分批处理：默认_update_by_query每次处理1000条文档，如果目标文档数量极多，可以通过size参数调整批次大小，但建议不要设置过大，避免给ES集群造成压力。
• 脚本权限：ES 6.x默认允许painless脚本执行这类简单的字段更新操作，如果你修改过集群的脚本权限配置，需要确保script.allowed_types包含inline或stored。

这样就能一次性把所有符合条件的文档更新完成，不用再逐个处理文档ID啦～

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