如何在ElasticSearch中实现跨索引字段更新（类SQL关联更新）

要实现你需求的将index2的字段更新到index1对应文档（类似SQL的关联更新），可以在ES Dev Tools中使用_update_by_query API结合Painless脚本完成，以下是具体操作：

核心操作代码（针对你的示例场景） #

POST /index1/_update_by_query
{
  "script": {
    "source": """
      // 根据当前文档ID从index2获取对应文档
      def target_doc = ctx._get['index2'].get(ctx._id);
      if (target_doc != null) {
        // 将index2的content2字段赋值给index1的对应字段
        ctx._source.content2 = target_doc._source.content2;
      }
    """,
    "lang": "painless"
  },
  "query": {
    "match_all": {}
  }
}

代码说明 #

• ctx._get['index2'].get(ctx._id)：利用当前index1文档的_id，直接从index2中拉取同ID的文档数据
• 条件判断确保只有在index2存在对应文档时才执行更新，避免空值覆盖
• match_all会匹配index1所有文档，如果你只想更新特定文档，可替换为精准查询（比如{"term": {"_id": "A"}}）

执行效果 #

运行上述请求后，index1中ID为A的文档会被更新为：

id = A
content1 = "a"
content2 = "asdf"

注意事项 #

• 确保ES集群允许使用Painless脚本（默认开启，若有配置限制需调整script.allowed_types等参数）
• 若涉及大量文档更新，建议在业务低峰期执行，避免影响集群性能
• 如果关联条件不是基于_id，而是其他字段（比如field2），可先通过terms查询获取关联ID列表，再结合脚本完成批量更新

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