Elasticsearch 在 ElasticSearch API 与 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 和问题来自您的映射的“陈旧”版本，该版本与您的脚本最终会调整的内容不兼容。检查 my other answer from a while ago 以更深入地了解这个听起来很神秘的错误。

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

{
  "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 并使用它重写我的更新并且它工作正常。 由于我不需要检查响应，因此我也不需要解析它。