Apache NIFI：UpdateRecord替换子值

Question

我试图使用UpdateRecord1.9.0处理器修改一个JSON，但它并没有像我想要的那样替换这些值。

{
    "type": "A",
    "ids": [{
            "id": "1",
            "value": "abc"
        }, {
            "id": "2",
            "value": "def"
        }, {
            "id": "3",
            "value": "ghi"
        }
    ]
}

{
    "ids": [{
            "userId": "1",
        }, {
            "userId": "2",
        }, {
            "userId": "3",
        }
    ]
}

和'id'和'value',而ID则使用'userid'字段来代替'id'和'value'。

为了填充userId的值，我定义了replace策略和要replace的属性：strategy

但输出是错误的。userId总是用数组中最后一个元素的id填充：

{
    "ids": [{
            "userId": "3"
        }, {
            "userId": "3"
        }, {
            "userId": "3"
        }
    ]
}

我做错了什么？

谢谢

Answer 1

最后，我使用了JoltJSONTransform处理器而不是UpdateRecord

JoltJsonTransform

模板：

[
    {
        "operation": "shift",
        "spec": {
            "ids":{
                "*":{
                    "id": "ids[&1].userId"
                }
            }
        }
    }
]

比UpdateRecord容易