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

Question

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

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

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

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

Answer 1

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

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