apache-nifi - 在处理器中查找流文件的出处数据

我正在尝试开发一个 NiFi 处理器，它可以扩展内置处理器“监控活动”的功能。

我试图解决的问题是，在我的应用程序中，我将有多个流进入处理器，当在特定时间段内没有流文件到达时，处理器会通过电子邮件发出警报。但是，如果只有一个流停止，则不会触发警报。

我想修改处理器，使其能够区分不同的流并相应地发出警报。

为了做到这一点，我需要一种方法来区分源自一个处理器和另一个处理器的流文件。我知道 NiFi 保留了可以从 GUI 界面中轻松访问的详细出处记录，但我无法找到从处理器代码中以编程方式访问此信息的简单方法。

标签： apache-nififlowfile