ControllerStatusReportingTask

文档中心 › 组件索引 › ControllerStatusReportingTask

ControllerStatusReportingTask Reporting Task

类型全限定名:cn.org.acal.lynxus.controller.ControllerStatusReportingTask

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

记录 Lynxus 摘要页面中显示的处理器和连接的 5 分钟统计信息,还可以选择记录上一次迭代和当前迭代之间的增量。 处理器的统计信息使用 cn.org.acal.lynxus.controller.ControllerStatusReportingTask.Processors 记录器记录,而连接的统计信息使用 cn.org.acal.lynxus.controller.ControllerStatusReportingTask.Connections 记录器记录。 如果需要,可以在 Lynxus 日志记录配置中配置这些以记录到不同的文件。

标签

statslog

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
Show Deltastrue
  • true
  • false
指定是否显示当前状态与前一状态之间的值差异
Reporting Granularityfive-minutes
  • 五分钟 — 报告的统计信息将反映最近 5 分钟的处理数据,与 UI 中显示的统计信息一致。
  • 一秒 — 报告的统计信息将是过去 5 分钟内每秒值的平均值。这基本上是通过将 UI 中显示的统计信息除以 300(5 分钟内的 300 秒)获得的,除非 Lynxus 运行时间不足 5 分钟。在这种情况下,统计信息将除以 Lynxus 实际运行的时间。
报告信息时,指定要报告的指标的粒度

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

详细说明

ControllerStatusReportingTask

说明

该 Reporting Task 会为流程中的每个 Processor 和每个 Connection 生成一条日志消息。对于 Processor, 包含以下信息(按处理耗时降序排列):

  • Processor 名称
  • Processor ID
  • Processor 类型
  • 运行状态
  • 进入的 FlowFile 数(5 分钟)
  • 输出的 FlowFile 数(5 分钟)
  • 从磁盘读取的字节数(5 分钟)
  • 写入磁盘的字节数(5 分钟)
  • 完成的任务数(5 分钟)
  • 处理耗时(5 分钟)

对于 Connection,包含以下信息(按排队中的 FlowFile 数量降序排列):

  • Connection 名称
  • Connection ID
  • 源组件名称
  • 目标组件名称
  • 进入的 FlowFile 数(5 分钟)
  • 输出的 FlowFile 数(5 分钟)
  • 排队中的 FlowFile 数

将本 Reporting Task 的日志输出重定向到一个独立于常规应用日志的日志文件,往往会更方便。可以通过修改 Lynxus conf/ 目录下的 logback.xml 文件,为名为 cn.org.acal.lynxus.controller.ControllerStatusReportingTask 的 logger 配置单独的日志输出,来实现这一点。

此外,可能还需要单独关闭 Processor 或 Connection 的日志,或者将两者拆分到不同的日志文件中。可以分别 使用名为 cn.org.acal.lynxus.controller.ControllerStatusReportingTask.Processors 和 cn.org.acal.lynxus.controller.ControllerStatusReportingTask.Connections 的 logger 来实现。