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

Additional Details...

Tags: monitor, flow, active, inactive, activity, detection

Properties:

In the list below, the names of required properties appear in bold. Anyother properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language (or simply EL), and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.

NameDescriptionDefault ValueValid ValuesELSensitive
Threshold DurationDetermines how much time must elapse before considering the flow to be inactive5 minNoNo
Continually Send MessagesIf 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 inactivefalse
  • true
  • false
NoNo
Inactivity MessageThe message that will be the content of FlowFiles that are sent to the 'inactive' relationshipLacking activity as of time: ${now():format('yyyy/MM/dd HH:mm:ss')}; flow has been inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutesYesNo
Activity Restored MessageThe message that will be the content of FlowFiles that are sent to 'activity.restored' relationshipActivity restored at time: ${now():format('yyyy/MM/dd HH:mm:ss')} after being inactive for ${inactivityDurationMillis:toNumber():divide(60000)} minutesYesNo
Copy AttributesIf true, will copy all flow file attributes from the flow file that resumed activity to the newly created indicator flow filefalse
  • true
  • false
NoNo

Relationships:

NameDescription
activity.restoredThis relationship is used to transfer an Activity Restored indicator when FlowFiles are routing to 'success' following a period of inactivity
inactiveThis relationship is used to transfer an Inactivity indicator when no FlowFiles are routed to 'success' for Threshold Duration amount of time
successAll incoming FlowFiles are routed to success