如何在写入ElasticSearch时使用Update API无痛连接对象而不是整个对象进行替换

问题描述

方案:在ElasticSearch上有一个文档A,我想在此文档上连接文档B上存在的某些字段。

文档A:

{ 
    "id": 121423,"name": "Sample Name","timestamp": "2020-10-01T00:12:00","age": 24
}

文档B:

{
    "city": "New York","job": "programmer"
}

要编写此文档,我可以使用write ES路径和类似它的正文:

{"update":{"_index":"test-index","_id":"121423"}}
{"script": {"source":"if( ctx._source.containsKey('id') ){   ctx._source = params.param1; }","lang":"painless","params":{"param1":{"city": "New York","job": "programmer"}}},"upsert":{"id":121423,"age": 24}}

但是,如果文档A在ES上存在,例如check do(if( ctx._source.containsKey('id') )),则该文档将被完全覆盖。我可以替换归因的参数来逐步选择每个元素,例如:

{   ctx._source.city = params.param1.city; ctx._source.job = params.param1.job }

那将解决我的问题,但是这给我带来了一个问题,逻辑不能是静态的,因为在现实世界中,文档具有许多(非常多)字段,并且对应用程序的支持会很困难。上次更新时所需的文档必须类似于:

{ 
    "id": 121423,"age": 24,"city": "New York","job": "programmer"
}

所以,问题是,如何以很少的步骤或仅使用一个运算符来更新附加新字段的文档?

解决方法

您可能应该只添加“ doc_as_upsert”:是 我从来没有尝试过使用脚本,但是应该可以。

{ "update" : {"_id" : "2","_index" : "index1","retry_on_conflict" : 3} }
{ "doc" : {"field" : "value"},"doc_as_upsert" : true }