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 |
Specify how to determine activeness of the flow. “node” means that activeness is examined at individual node separately. It can be useful if DFM expects each node should receive flow files in a distributed manner. With “cluster”, it defines the flow is active while at least one node receives flow files actively. If NiFi is running as standalone mode, this should be set as “node”, if it “s” cluster “, NiFi logs a warning message and act as” node’scope. |
Reporting Node |
Specify which node should send notification flow-files to inactive and activity.restored relationships. With “all”, every node in this cluster send notification flow-files. “primary” means flow-files will be sent only from a primary node. If NiFi is running as standalone mode, this should be set as “all”, even if it “s” primary “, NiFi act as” 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é |