Description:
Monitors the flow for activity and sends out an indicator when the flow has not had any data for some specified amount of time and again when the flow’s activity is restored
Tags:
monitor, flow, active, inactive, activity, detection
Properties:
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the Expression Language Guide.
Name | Default Value | Allowable Values | Description |
Threshold Duration | 5 min | Determines how much time must elapse before considering the flow to be inactive | |
Continually Send Messages | false |
* true * false |
If true, will send inactivity indicator continually every Threshold Duration amount of time until activity is restored; if false, will send an indicator only when the flow first becomes inactive |
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 |
The message that will be the content of FlowFiles that are sent to the 'inactive' relationship Supports Expression Language: true |
|
Activity Restored Message | Activity restored at time: ${now():format('yyyy/MM/dd HH:mm:ss')} after being inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutes |
The message that will be the content of FlowFiles that are sent to 'activity.restored' relationship Supports Expression Language: true |
|
Copy Attributes | false |
* true * false |
If true, will copy all flow file attributes from the flow file that resumed activity to the newly created indicator flow file |
Relationships:
Name | Description |
activity.restored | This relationship is used to transfer an Activity Restored indicator when FlowFiles are routing to 'success' following a period of inactivity |
inactive | This relationship is used to transfer an Inactivity indicator when no FlowFiles are routed to 'success' for Threshold Duration amount of time |
success | All incoming FlowFiles are routed to success |
Reads Attributes:
None specified.
Writes Attributes:
Name | Description |
inactivityStartMillis | The time at which Inactivity began, in the form of milliseconds since Epoch |
inactivityDurationMillis | The number of milliseconds that the inactivity has spanned |