时间戳

首页 > 解决方案 > Elasticsearch 使用 ElasticSearch API 与 java API 中的无痛脚本更新嵌套字段

java - 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]]

尝试了不同的选项，空车场，满车场，每次都出现上述异常。

标签： javaelasticsearchelasticsearch-painlesselasticsearch-java-apielasticsearch-scripting

解决方案

您的 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) }

推荐阅读