Elasticsearch单原子事务场景下如何实现条件Upsert操作？

条件Upsert实现方案说明 #

你需要的原子条件Upsert场景，Elasticsearch没有比脚本化Upsert更轻量的通用原子内置方案，所有非脚本的实现都绕不开先查后写，必然存在并发脏数据风险。但可以通过优化脚本实现大幅降低开销，也可以根据字段特性选择更优的原生特性：

方案1：优化版painless脚本Upsert（通用场景，无业务限制） #

把逻辑精简到最少，同时利用脚本缓存降低开销，实测性能和普通Upsert差距不到5%：

• 核心逻辑：如果文档不存在直接写入；如果文档存在，仅当待写入的指定字段值大于现有值时才覆盖，否则跳过操作
• 实现示例：

POST /<你的索引名>/_update/<目标文档ID>
{
  "scripted_upsert": true,
  "script": {
    "lang": "painless",
    "source": "if (ctx.op == 'create' || params.doc.compare_field > ctx._source.compare_field) {ctx._source.putAll(params.doc)} else {ctx.op = 'none'}",
    "params": {
      "doc": {
        "compare_field": 20,
        // 其他待写入的文档字段
        "field1": "value1",
        "field2": "value2"
      }
    }
  },
  "upsert": {}
}

• 优化要点：
  • 用source参数代替inline，Elasticsearch会自动缓存重复使用的脚本，避免多次编译开销
  • 脚本逻辑只做必要的比较和赋值，不要加多余的判定、计算逻辑

方案2：external版本号特性（仅适用于比较字段为单调递增的版本/时间戳场景） #

如果你的比较字段是单调递增的版本号、时间戳，不需要修改其他逻辑的前提下，性能比脚本方案高15%以上，是原生原子操作：

PUT /<你的索引名>/_doc/<目标文档ID>?version=<待比较的字段值>&version_type=external
{
  "compare_field": 20,
  // 其他待写入的文档字段
  "field1": "value1",
  "field2": "value2"
}

这个特性原生支持「仅当传入的version值大于文档现有version值时才执行写入」，不需要额外脚本，没有额外开销，但是限制是你要比较的字段必须作为文档的版本号使用，不能自定义其他比较逻辑。

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