本文主要是介绍NiFi Reporting Tasks介绍,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Reporting Tasks
到目前为止, 我们很少提到如何向外界传达 NiFi 及其组件的性能。
系统是否能够跟上传入的数据速率? 系统还能承受多少? 在一天的高峰时间处理了多少数据, 而在一天最不忙的事件处理了多少数据?
为了回答这些问题以及更多的问题, NiFi 通过 ReportingTask接口提供了向外部服务报告状态, 统计信息, 度量和监视信息的功能。ReportingTasks被赋予对大量信息的访问权限, 以确定系统是如何执行的。
Developing a Reporting Task
与Precossor和ControllerService接口一样, ReportingTask接口公开用于配置, 验证和初始化方法。这些方法都与Processor 和ControllerService接口的方法相同, 只是initialize方法传递了一个ReportingConfiguration对象, 而不是其他组件接收到的初始化对象。
ReportingTask还有一个onTrigger方法,框架会调用该方法来触发任务来执行它的工作。
在onTrigger方法中,ReportingTask被授予对ReportingContext的访问权,可以从这个context中获得关
这篇关于NiFi Reporting Tasks介绍的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!