MonitorActivity 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Surveille l’activité du flux et envoie un indicateur lorsque le flux n’a pas reçu de données pendant une période donnée, puis à nouveau lorsque l’activité du flux est rétablie
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Activity Restored Message |
Le message qui constituera le contenu de FlowFiles envoyé à la relation “activity.restored” |
Continually Send Messages |
Si “true”, enverra l’indicateur d’inactivité en continu toutes les durées définies par la propriété Threshold Duration jusqu’à ce que l’activité soit rétablie ; si “false”, enverra un indicateur uniquement lorsque le flux devient inactif pour la première fois |
Copy Attributes |
Si true, copiera tous les attributs du FlowFile qui a repris l’activité vers le flux de fichiers indicateur nouvellement créé |
Inactivity Message |
Le message qui constituera le contenu de FlowFiles envoyés à la relation “inactive” |
Monitoring Scope |
Permet de spécifier comment déterminer l’activité du flux. « node » (nœud) signifie que l’activité est examinée séparément au niveau des nœuds individuels. Cela peut être utile si DFM s’attend à ce que chaque nœud reçoive les fichiers de flux de façon distribuée. Avec « cluster », définit que le flux est actif alors qu’au moins un nœud reçoit activement des fichiers de flux. Si NiFi s’exécute en mode autonome, doit être défini sur « node », si défini sur cluster, NiFi enregistre un message d’avertissement et agit en tant que « node scope » (portée de nœud). |
Reporting Node |
Spécifiez quel nœud doit envoyer les fichiers de flux de notification aux relations inactives et activity.restored (activités.restaurées). Avec « tous », chaque nœud de ce cluster envoie des fichiers de flux de notification. « primary » (principal) signifie que les fichiers de flux seront envoyés uniquement à partir d’un nœud principal. Si NiFi s’exécute en mode autonome, « all » (tout) doit être défini, même si s’il s’agit d’un « principal », NiFi agit comme « all ». |
Reset State on Restart |
Lorsque le processeur est démarré ou redémarré, si défini sur “true”, l’état initial sera toujours actif. Sinon, le dernier état du flux signalé sera conservé. |
Threshold Duration |
Détermine le temps qui doit s’écouler avant de considérer le flux comme inactif. |
Wait for Activity |
Lorsque le processeur est démarré ou redémarré, si défini sur “true”, envoie uniquement un indicateur d’inactivité s’il y a eu de l’activité auparavant. Sinon, envoie un indicateur d’inactivité même s’il n’y a pas eu d’activité auparavant. |
Gestion de l’État¶
Champs d’application |
Description |
|---|---|
LOCAL |
MonitorActivity stocke le dernier horodatage à chaque nœud en tant qu’état, afin de pouvoir examiner l’activité à l’échelle du cluster. Si “Copy Attribute” est défini sur “true”, les attributs du FlowFile sont également conservés. En mode local, il stocke l’horodatage de la dernière activité connue si le flux est inactif. |
CLUSTER |
MonitorActivity stocke le dernier horodatage à chaque nœud en tant qu’état, afin de pouvoir examiner l’activité à l’échelle du cluster. Si “Copy Attribute” est défini sur “true”, les attributs du FlowFile sont également conservés. En mode local, il stocke l’horodatage de la dernière activité connue si le flux est inactif. |
Relations¶
Nom |
Description |
|---|---|
activity.restored |
Cette relation est utilisée pour transférer un indicateur d’activité rétablie lorsque les FlowFiles sont routés vers “success” après une période d’inactivité |
inactive |
Cette relation est utilisée pour transférer un indicateur d’inactivité lorsqu’aucun FlowFiles n’est routé vers “success” pendant la durée définie par Threshold Duration. |
success |
Tous les FlowFiles entrants sont routés vers le succès |
Écrit les attributs¶
Nom |
Description |
|---|---|
inactivityStartMillis |
Heure à laquelle l’inactivité a commencé, sous forme de millisecondes depuis Epoch |
inactivityDurationMillis |
Le nombre de millisecondes que l’inactivité a duré |