apache-nifi - 在 NiFi 中将两个 JSON 流文件合并在一起

Question

我想通过相同的指定属性合并两个包含 JSON 对象的流文件...

流 1:

attribute:    
xuuid = 123456

content:
{
"sname":"jack",
"id":"00001",
"state":"NY"
}

流 2:

attribute:    
xuuid = 123456

content:
{
"country":"US",
"date":"1983"
}

我希望在单个输出流中出现这种形式的数据:

required_flow:

attribute:    
xuuid = 123456

content:
{
"sname":"jack",
"id":"00001",
"state":"NY",
"country":"US",
"date":"1983"
}

我怎么玩这个？ MergeContent 处理器还是 MergeRecord？
我认为 mergeecord 可以处理它，但我对此感到困惑。

Answer 1

是的 MergeContent 可以为您做到这一点。

我用 EvalJson --> 合并内容 --> AttributesToJson

我在这里发布了一个模板，你可以用来玩。
Apache NiFi Merge Json Template

合并内容 必须有这样的设置:“保留所有属性”、“2 个整数”、“分隔符策略是文本”