1

有人可以解释 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]]

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

4

2 回答 2

1

您的 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) }
于 2021-02-12T16:34:04.473 回答
0

好像我向 RestHighLevelClient 投降了。但我记得我有 LowLevelClient 并使用它重写我的更新,它工作正常。因为我不需要检查响应,所以我也不需要解析它。

于 2021-02-12T19:14:50.673 回答