MonitorActivity 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

监控流的活动情况：当在指定时间内未检测到任何数据流动时，发出一个指示信号；流活动恢复后，再次发出指示信号。

标签¶

active、activity、detection、flow、inactive、monitor

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
活动已恢复消息	将作为 FlowFiles 内容发送至“activity.restored”关系的消息
持续发送消息	如果为 True，将在每个最短持续时间范围内持续发送不活动指示信号，直到恢复活动状态；如果为 False，则仅在流首次处于非活动状态时发送指示信号
复制属性	如果为 True，则会将所有 FlowFile 属性从恢复活动状态的 FlowFile 复制到新创建的指示信号 FlowFile 中
非活动消息	将作为 FlowFiles 内容发送至“inactive”关系的消息
监控范围	指定如何确定流的活动性。“节点”表示单独检查单个节点的活动性。如果 DFM 期望每个节点都应以分布式方式接收 FlowFile，则会很有用。它使用“集群”定义流处于活动状态，同时至少一个节点主动接收 FlowFile。如果 NiFi 以独立模式运行，则应将其设置为“节点”，如果是“集群”，则 NiFi 记录警告消息并充当“节点”范围。
报告节点	指定哪个节点应向“inactive”关系和“activity.restored”关系发送通知流文件。如果设置为“all”，此集群中的每个节点都会发送通知流文件。“primary”表示流文件将仅从主节点发送。如果 NiFi 以独立模式运行，则应将其设置为“all”，即使是“primary”，NiFi 也相当于“all”。
重启时重置状态	当处理器启动或重新启动时，如果设置为 True，则初始状态将始终处于活动状态。否则，将保留上次报告的流状态。
持续时间下限	确定必须经过多长时间才能将流视为不活动状态
等待活动	当处理器启动或重新启动时，如果设置为 True，则仅在事先有活动时才发送不活动指示信号。否则，即使事先没有活动，也会发送不活动指示信号。

状态管理¶

范围	描述
CLUSTER	MonitorActivity 将每个节点的最后一个时间戳存储为状态，以便它可以检查集群范围内的活动。如果“复制属性”设置为 True，则 FlowFile 属性也会被保留。在本地范围内，如果流处于非活动状态，它会存储上次已知的活动时间戳。
LOCAL	MonitorActivity 将每个节点的最后一个时间戳存储为状态，以便它可以检查集群范围内的活动。如果“复制属性”设置为 True，则 FlowFile 属性也会被保留。在本地范围内，如果流处于非活动状态，它会存储上次已知的活动时间戳。

关系¶

名称	描述
activity.restored	此关系用于 FlowFiles 在一段时间不活动后路由至“success”时，传输“活动已恢复”指示信号。
inactive	此关系用于在“持续时间下限”内无 FlowFiles 路由至“success”时，传输“Inactivity”指示信号。
success	所有传入的 FlowFiles 都将路由至 success

写入属性¶

名称	描述
inactivityStartMillis	“Inactivity”状态开始的时间，以自 Unix 纪元起的毫秒为单位。
inactivityDurationMillis	“Inactivity”状态持续的毫秒数