MonitorActivity - ACAL Lynxus 组件文档

MonitorActivity Processor

类型全限定名：cn.org.acal.lynxus.processors.standard.MonitorActivity

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

描述

监视流的活动，并在流在指定时间内没有任何数据时发出指示符，并在流的活动恢复时再次发出指示符

标签

monitorflowactiveinactiveactivitydetection

属性

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

名称	默认值	可选值	描述
Threshold Duration	`5 min`		确定在考虑流处于非活动状态之前必须经过多长时间支持表达式语言：是（仅使用环境/系统变量求值）
Continually Send Messages	`false`	true false	如果为 true，将每隔阈值持续时间持续发送不活动指示器，直到活动恢复；如果为 false，则仅在流首次变为不活动时发送指示器。
Inactivity Message	`Lacking activity as of time: ${now():format('yyyy/MM/dd HH:mm:ss')}; flow has been inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutes`		该消息将作为发送到“非活动”关系的 FlowFiles 的内容支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Activity Restored Message	`Activity restored at time: ${now():format('yyyy/MM/dd HH:mm:ss')} after being inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutes`		该消息将作为发送到“activity.restored”关系的 FlowFiles 的内容支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Wait for Activity	`false`	true false	当处理器启动或重启时，如果设置为 true，仅在有之前的活动时才发送不活动指示器。否则即使之前没有活动也会发送不活动指示器。
Reset State on Restart	`true`	true false	当处理器启动或重启时，如果设置为 true，初始状态将始终为活动。否则，将保留上次报告的流状态。
Copy Attributes	`false`	true false	如果为 true，则将恢复活动的 FlowFile 中的所有 FlowFile 属性复制到新创建的指标 FlowFile
监控范围	`node`	node cluster	指定如何确定流程的活动状态。'node' 表示在各个节点单独检查活动状态。当 DFM 期望每个节点应以分布式方式接收 FlowFile 时，这可能很有用。使用 'cluster' 时，只要至少一个节点活跃地接收 FlowFile，就定义流程为活动状态。如果 Lynxus 以独立模式运行，则应设置为 'node'，如果设置为 'cluster'，Lynxus 会记录警告消息并以 'node' 范围运行。
报告节点	`all`	all primary	指定哪个节点应向 inactive 和 activity.restored 关系发送通知 FlowFile。使用 'all' 时，集群中的每个节点都发送通知 FlowFile。'primary' 表示 FlowFile 仅从主节点发送。如果 Lynxus 以独立模式运行，则应设置为 'all'，即使设置为 'primary'，Lynxus 也会以 'all' 方式运行。

关系 (Relationships)

名称	描述	自动终止
`activity.restored`	此关系用于传输活动恢复指示器，当 FlowFile 在一段不活动期间后重新路由到 'success' 时触发	否
`inactive`	此关系用于传输不活动指示器，当在阈值持续时间内没有 FlowFile 路由到 'success' 时触发	否
`success`	所有传入的 FlowFile 都会成功路由	否

写入的 FlowFile 属性

名称	描述
`inactivityStartMillis`	不活跃开始的时间，以自纪元以来的毫秒数表示
`inactivityDurationMillis`	不活动所持续的毫秒数

状态管理

作用域	描述
CLUSTER、LOCAL	MonitorActivity 将每个节点的最后时间戳存储为状态，以便可以检查集群范围的活动。如果'复制属性'设置为 true，则 FlowFile 属性也会被持久化。在本地范围中，如果流不活动，则存储最后已知的活动时间戳。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。