多个流文件的单个通知邮件 Nifi
Single notification mail for multiple flow files Nifi
我正在尝试使用 nifi 从数据库复制数据并将其放入 S3。我能够从数据库复制数据并将其放在 S3 中。现在我正在尝试为此流程添加错误处理。我刚刚添加了用于错误通知的 PutEmail 处理器。我只是给了一个错误的桶名来验证电子邮件。每个流文件都会触发此 PutEmail 处理器(因为有 100 个流文件,邮件会触发 100 次)。我只想在流程中出现错误时仅触发此 PutEmail(notification) 一次。请对此提出任何建议。
流程如下:
任何关于更好(通用)错误处理的建议都会对我有所帮助。
对于您的用例,MergeContent 将允许您在给定的持续时间内对多个 FlowFile 进行批处理,以汇总到一封电子邮件中。
您还可以进行一些额外的转换以仅获取内容的关键部分 and/or 属性以向 MergeContent 提供源 FlowFiles,从而在发送的消息中提供摘要列表。
您可以实施自定义 ReportingTasks,它会根据需要定期发送报告
我正在尝试使用 nifi 从数据库复制数据并将其放入 S3。我能够从数据库复制数据并将其放在 S3 中。现在我正在尝试为此流程添加错误处理。我刚刚添加了用于错误通知的 PutEmail 处理器。我只是给了一个错误的桶名来验证电子邮件。每个流文件都会触发此 PutEmail 处理器(因为有 100 个流文件,邮件会触发 100 次)。我只想在流程中出现错误时仅触发此 PutEmail(notification) 一次。请对此提出任何建议。
流程如下:
任何关于更好(通用)错误处理的建议都会对我有所帮助。
对于您的用例,MergeContent 将允许您在给定的持续时间内对多个 FlowFile 进行批处理,以汇总到一封电子邮件中。
您还可以进行一些额外的转换以仅获取内容的关键部分 and/or 属性以向 MergeContent 提供源 FlowFiles,从而在发送的消息中提供摘要列表。
您可以实施自定义 ReportingTasks,它会根据需要定期发送报告