MonitorActivity 2025.5.31.15¶
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 |
Indiquer comment déterminer l’activité du flux. “node” signifie que l’activité est examinée au niveau de chaque nœud séparément. Elle peut être utile si DFM prévoit que chaque nœud reçoive des fichiers de flux de manière distribuée. Et “cluster” signifie que le flux est actif si au moins un nœud reçoit des FlowFiles de manière active. Si NiFi fonctionne en mode autonome, cette valeur doit être définie sur “node”. Si elle est définie sur “cluster”, NiFi consigne un message d’avertissement et agit comme en mode “node”. |
Reporting Node |
Spécifie quel nœud doit envoyer les fichiers de flux de notification vers les relations “inactive” et “activity.restored”. Avec “all”, chaque nœud de ce cluster envoie des FlowFiles de notification. “primary” signifie que les FlowFiles ne seront envoyés qu’à partir d’un nœud principal. Si NiFi fonctionne en mode autonome, cette valeur doit être définie sur “all”. Même si elle est définie sur “primary”, 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 |
|---|---|
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. |
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. |
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é |