多个流文件的单个通知邮件 Nifi

Question

我正在尝试从数据库中复制数据并使用 nifi 将其放置在 S3 中。我能够从数据库中复制数据并将其放置在 S3 中。现在我正在尝试为此流程添加错误处理。我刚刚添加了用于错误通知的 PutEmail 处理器。我只是给了一个错误的存储桶名称来验证电子邮件。这个 PutEmail 处理器被每个流文件触发（因为有 100 个流文件，邮件触发了 100 次）。我只想在流程中出现错误时仅触发一次 PutEmail(notification)。请对此提出任何建议。

下面是流程：

任何关于更好（通用）错误处理的建议都会对我有所帮助。

Answer 1

对于您的用例，MergeContent将允许您在给定的持续时间内批量处理多个 FlowFile，以汇总到一封电子邮件中。

您还可以进行一些额外的转换，以仅获取内容和/或属性的关键部分，以将源 FlowFiles 提供给 MergeContent，从而在发送的消息中提供摘要列表。