问题描述
我正在尝试开发一种 NiFi 处理器,以扩展内置处理器“监控活动”的功能。
我试图解决的问题是,在我的应用程序中,我会有多个流进入处理器,当在特定时间段内没有流文件到达时,处理器会通过电子邮件发出警报。但是,如果只有一个流停止,则不会触发警报。
我想修改处理器,使其能够区分不同的流并相应地发出警报。
为了做到这一点,我需要一种方法来区分源自一个处理器和另一个处理器的流文件。 我知道 NiFi 保留了详细的出处记录,可以从 GUI 界面中轻松访问这些记录,但我无法找到一种从处理器代码中以编程方式访问此信息的简单方法。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)