apache-nifi - Apache Nifi，我可以从多个流文件中收集一个属性吗

Question

我有一个 nifi 流，它接收 .csv 文件并将每个文件划分为多个记录，每个 csv 列值作为属性添加。

在流程中的某一时刻，我想从通过的每条记录中收集一个属性的值。可能有从 0 到 n 收集。一旦我有了清单，它就会通过电子邮件发送出去。如果文件中有 200 多个不良记录，我会尽量避免我（或其他人）被电子邮件轰炸。因此，如果我可以收集一段固定的时间或直到另一个属性（文件名）发生变化，那就太好了。

我试过合并内容和记录。我什至尝试用替换文本来替换内容，只包含我想要保存和合并的属性值，以及许多其他内容。

有没有一种简单的方法可以在 nifi 中做到这一点？

标签： apache-nifi

Answer 1

您是否尝试过使用数组类型的新属性的 UpdateAttribute。当每个流文件通过此处理器时，您可以通过将新值附加到数组属性来继续更新此属性的值。

但是，正如@daggett 指出的那样，如果您可以提供输入和预期输出，将会很有帮助。