如何在 NiFi 中将错误从处理器传递到 PutEmail 处理器

问题描述

在下图中,我们可以清楚地看到 Conversion_Batching 处理器中的错误。如何将此错误传输到 PutEmail,以便电子邮件收件人可以清楚地了解错误

enter image description here

以下是 PutEmail 配置:

enter image description here

但是 ${error} 没有收到来自前一个处理器的错误,我收到一封空邮件主题设置正确。

请帮忙看看怎么做?

解决方法

NiFi 目前没有可以捕获异常/错误并将其作为属性或流文件内容传递给后续处理器的功能。

您可以配置使用站点到站点协议发布公告事件的 SiteToSiteBulletinReportingTask。这将为您提供 bulletinsourceid,bulletinsourcename,bulletingroupname,bulletinmessage 等信息,然后您可以根据这些信息发送警报通知电子邮件。

另一种方法是在您的进程组 Conversion_Batching 中引入属性 ${error} 并在发生故障的任何地方设置自定义错误消息,然后您可以在 PutEmail 处理器中使用此属性值,如下所示,>

erro_handeling

error_attribute

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...