Elasticsearch：更新/更新文档中的数组字段，但忽略某些现有字段

Question

获取_doc/1

"_source": {
"documents": [
    {
        "docid": "ID001",
        "added_vals": [
            {
                "code": "123",
                "label": "Abc"
            },
            {
                "code": "113",
                "label": "Xyz"
            }
        ]
    },
    {
        "docid": "ID002",
        "added_vals": [
            {
                "code": "123",
                "label": "Abc"
            }
        ]
    }
],
"id": "1"
}

POST /_bulk

{ "update": { "_id": "1"}}
{ "doc": { "documents": [ { "docid": "ID001", "status" : "cancelled" } ], "id": "1" }, "doc_as_upsert": true }

上面的问题是当我运行批量更新脚本时，它会替换该文档字段，删除 added_vals 列表。我可以使用无痛脚本来实现这一点吗？谢谢。

Answer 1

使用elasticsearch painless scripting

POST /_bulk

{ "update": { "_id": "1"} }
{ "scripted_upsert":true, "script" :{ "source": "if(ctx._version == null) { ctx._source = params; } else { def param = params; def src = ctx._source; for(s in src.documents) { boolean found = false; for(p in param.documents) { if (p.docid == s.docid) { found = true; if(s.added_vals != null) { p.added_vals = s.added_vals; } } } if(!found) param.documents.add(s); } ctx._source = param; }", "lang": "painless", "params" : { "documents": [ { "docid": "ID001", "status" : "cancelled" } ], "id": "1" } }, "upsert" : {  } } 

嗯，这个对我有用。我需要调整一些我需要的东西，但我会把它留给可能需要它的人。没想到这么简单。如果有任何其他可能更容易的答案，请提交。谢谢。

“脚本”：

if(ctx._version == null)
{
    ctx._source = params;
}
else
{
    def param = params;    
    def src = ctx._source;
    for(s in src.documents)
    {
        boolean found = false;
        for(p in param.documents)
        {
            if (p.docid == s.docid) 
            {
                found = true;
                if(s.added_vals != null)
                {
                    p.added_vals = s.added_vals;                    
                }
            }
        }
        if(!found) param.documents.add(s);
    }
    ctx._source = param;        
}

我不确定是否应该直接修改参数，所以我使用并将参数传递给 param 变量。我还使用了 scripted_upsert: true 和 ctx._version not null 检查。