如何在Nifi中测量每个处理器的执行时间



我需要输入和退出流中每个处理器的onTrigger方法的时间。

假设我有7个处理器,我还需要输入流中第一个处理器的onTrigger和退出流中最后一个处理器的onTrigger(或该流中任何其他3个链接的处理器(的时间。

我还需要从UI打开/关闭这个。

我最终实现了AspectJ,它非常有效。在所有处理器中,我添加了一个具有2个值(启用和禁用(的属性,我在aspect类中读取该属性以满足";从UI打开/关闭它";任务的一部分。

最新更新