使用nifi根据条件合并流文件？

Question

我有 3 个来自同一个处理器的流文件。

FF1 -> {a:1,b:2,c:'name'}

FF2 -> {a:1,b:5,c:'fruit'}

FF3 -> {a:2,b:3,c:'abc'}

通过使用 MergeContent 处理器，我可以合并所有流文件，但我的要求是在 Key 上合并流文件。

如果我使用 Key 'a' 加入时的预期输出：

FF1 -> [{a:1,b:2,c:'name'},{a:1,b:5,c:'fruit'}]

FF2 -> [{a:2,b:3,c:'abc'}]

Answer 1

MergeContent 有一个名为“相关属性”的属性，它是流文件属性的名称，用于将具有相同属性值（您示例中的键）的流文件组合在一起。

您需要使用 EvaluateJsonPath、ExtractText 或一些自定义脚本处理器等将字段“a”的值提取到流文件属性中，然后一旦进入“my.key”之类的属性，然后输入将“my.key”添加到相关属性属性中。