MonitorActivity

描述:

监视活动的数据流，并在数据流在指定的时间段内没有任何数据时发送指标，当数据流的活动恢复时再次发送指标。

标签:

monitor, flow, active, inactive, activity, detection, 监视, 活动, 察觉, 侦查

参数:

如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.

名字	默认值	允许值列表	描述
间隔时长	5 min		指定多长时间后被认定为非活动数据流
连续发送消息	禁止	- 允许 - 禁止	如果允许，将每个《间隔时长》时间就连续发送不活动指标，直到活动恢复；如果禁止，则仅当流首次变为不活动时才发送指标。
不活动消息	Lacking activity as of time: ${now():format('yyyy/MM/dd HH:mm:ss')}; flow has been inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutes		将作为发送到“inactive”连线的数据流内容的消息 支持表达式语言 (支持流属性和变量)
活动恢复消息	Activity restored at time: ${now():format('yyyy/MM/dd HH:mm:ss')} after being inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutes		将作为发送到“activity.restored”连线的数据流内容的消息 支持表达式语言 (支持流属性和变量)
拷贝属性	禁止	- 支持 - 禁止	如果拷贝，将从恢复活动的数据流的所有属性拷贝到新创建的数据流当中
监控范围	节点	- 节点 - 集群	指定监控的范围。“节点”表示在单个节点上分别检查活动性。如果DFM希望每个节点都以分布式方式接收数据流，那么这将非常有用。 对于集群，它定义当至少一个节点主动接收数据流时流是活动的。如果平台单机模式运行，则应该被设置为节点，如果选集群，平台将报警告并按节点处理
报告节点	所有	- 所有 - 主节点	指定应将通知数据流发送到“inactive” 和“activity.restored”的连线。对于所有节点，集群中的每个节点都发送数据流通知。而主节点表示仅主节点发送数据流。如果平台单机模式运行，则应该被设置为所有，如果选主节点，平台仍旧按所有节点处理

连线:

名字	描述
inactive	当在时间间隔时间内没有数据流输出到成功连线，则将路由都此非活动指标连线
success	数据流成功输出到此连线
activity.restored	当数据流输出到成功连线后一段时间非活动后，并且活动恢复后的数据流路由到连线

读取属性:

未提供。

写入属性:

名字	描述
inactivityStartMillis	非活动开始的时间（毫秒）
inactivityDurationMillis	非活动持续的时间（毫秒）

状态管理:

范围	描述
CLUSTER	组件将存储每个节点上的最后一个时间戳状态，以便它可以在集群范围内检查活动。如果支持《拷贝属性》，则属性也将被持久化

限制:

该组件没有限制

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。