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

Question

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

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

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

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”。键”到相关属性属性中。