json - 如何在NiFi中使用EvaluateJsonPath处理器拆分json

Question

我想在NiFi中拆分和传输json数据，这是我的json结构，如下所示；
我想通过将ID1，ID2数组的JSON转移到相应的处理器组来拆分JSON，例如示例processor_group a，b。我尝试使用json路径$ .id1，$。id2进行评估，但没有得到确切的解决方案。您能帮我解决这个问题吗？

{
    "id1": [{
        "u_name": "aa"
    }, {
        "addr": "bb"
    }],
    "id2": [{
        "u_name": "aa"
    }, {
        "addr": "bb"
    }]
}

Answer 1

您要查找的处理器是SplitJSON。
如下配置:


然后，您将收到两个FlowFiles:


第一个将包含id1:

[{
        "u_name": "aa"
    }, {
        "addr": "bb"
    }]

第二个将包含 id2:

[{
        "u_name": "aa"
    }, {
        "addr": "bb"
    }]