Elasticsearch 在 ElasticSearch API vs java API 中使用无痛脚本更新嵌套字段

Elasticsearch update nested field with painless script in ElasticSearch API vs java API

有人可以解释一下 ES java api 有什么问题吗? 我正在查询以使用 ES api 通过脚本进行更新,它运行良好(下)

POST user/ut/520411_5752/_update
{
  "script": {
    "source": "ctx._source.cars.add(params.car)",
    "params": {
      "car": {
        "pub_id":155,
        "name":"qwerty"
      }
    }
  }
}

和java

HashMap<String, Object> params = new HashMap<>();
params.put("car", GSON.toJson(car));

Script inline = new Script(ScriptType.INLINE, "painless",
"ctx._source.cars.add(params.car)", 
params);
    
UpdateRequest request = new UpdateRequest(USER, UT, id).script(inline).retryOnConflict(1);
UpdateResponse update = elasticClient.update(request, RequestOptions.DEFAULT);

如您所料,java 失败并出现异常

ElasticsearchStatusException[Elasticsearch exception [type=mapper_parsing_exception, reason=object mapping for [cars] tried to parse field [null] as object, but found a concrete value]]

尝试了不同的选项,空的 car 字段,填充的 car 字段,每次都会出现上述异常。

你的 java 代码 LGTM 和问题来自你的映射的“陈旧”版本,它与你的脚本最终调整的内容不兼容。检查 以更深入地了解这个听起来神秘的错误。

简单地说,确保您的映射看起来像这样:

{
  "mappings": {
    "properties": {
      "cars": {
        "type": "object",
        "properties": {
          "pub_id": {
            "type": "integer"
          },
          "name": {
            "type": "text"
          }
        }
      }
    }
  }
}

cars作为一个对象,其内容也明确定义。之后你的脚本应该可以正常工作了。

顺便说一句,为了绝对安全,我会在调用 .add:

之前再添加两次检查
if (ctx._source.cars != null && ctx._source.cars instanceof ArrayList) { ctx._source.cars.add(params.car) }

看来我放弃了 RestHighLevelClient。 但我记得我有 LowLevelClient 并使用它重写我的更新并且它工作正常。 因为我不需要检查响应,所以我也不需要解析它。