如何解决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 并使用它重写我的更新并且它工作正常。 由于我不需要检查响应,因此我也不需要解析它。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。