MonitorActivity 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Beschreibung¶
Überwacht den Datenfluss auf Aktivität und sendet eine Meldung, wenn der Datenfluss für einen bestimmten Zeitraum keine Daten empfangen hat, sowie erneut, wenn die Aktivität des Datenflusses wiederhergestellt ist.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Activity Restored Message |
Die Meldung, die den Inhalt von FlowFiles bildet, die an die Beziehung „activity.restored“ gesendet wird |
Continually Send Messages |
Bei „true“ wird der Inaktivitätsindikator kontinuierlich alle Threshold Duration-Zeiträume gesendet, bis die Aktivität wiederhergestellt ist. Bei „false“ wird ein Indikator nur gesendet, wenn der Fluss zum ersten Mal inaktiv wird. |
Copy Attributes |
Bei „true“ werden alle Attribute des FlowFile, das die Aktivität wieder aufgenommen hat, in das neu erstellte Indikator-FlowFile kopiert |
Inactivity Message |
Die Meldung, die den Inhalt der FlowFiles bildet, die an die Beziehung „inactive“ gesendet wird |
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 |
Wenn der Prozessor gestartet oder neu gestartet wird, ist der Anfangszustand immer aktiv, sofern diese Option auf „true“ gesetzt ist. Andernfalls wird der zuletzt gemeldete Flowd-Zustand beibehalten. |
Threshold Duration |
Legt fest, wie viel Zeit vergehen muss, bevor der Ablauf als inaktiv betrachtet wird |
Wait for Activity |
Wenn der Prozessor gestartet oder neu gestartet wird, wird – sofern auf „true“ gesetzt – nur dann ein Inaktivitätsindikator gesendet, wenn zuvor eine Aktivität stattgefunden hat. Andernfalls senden Sie einen Inaktivitätsindikator, auch wenn zuvor keine Aktivität stattgefunden hat. |
Statusmanagement¶
Bereiche |
Beschreibung |
|---|---|
LOCAL |
MonitorActivity speichert den letzten Zeitstempel an jedem Knoten als Status, sodass die Aktivität im gesamten Cluster überprüft werden kann. Wenn „Copy Attribute“ auf „true“ gesetzt ist, werden auch die Attribute des FlowFile beibehalten. Im lokalen Bereich speichert es den Zeitstempel der letzten bekannten Aktivität, wenn der Ablauf inaktiv ist. |
CLUSTER |
MonitorActivity speichert den letzten Zeitstempel an jedem Knoten als Status, sodass die Aktivität im gesamten Cluster überprüft werden kann. Wenn „Copy Attribute“ auf „true“ gesetzt ist, werden auch die Attribute des FlowFile beibehalten. Im lokalen Bereich speichert es den Zeitstempel der letzten bekannten Aktivität, wenn der Ablauf inaktiv ist. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
activity.restored |
Diese Beziehung wird verwendet, um den Indikator Activity Restored zu übertragen, wenn FlowFiles nach einer Zeit der Inaktivität an die Beziehung „success“ weitergeleitet wird. |
inaktiv |
Diese Beziehung wird verwendet, um einen Inaktivitätsindikator zu übertragen, wenn für eine bestimmte Zeitspanne (Threshold Duration) kein FlowFiles an „success“ weitergeleitet wurde. |
success |
Alle eingehenden FlowFiles werden an die Beziehung „success“ weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
inactivityStartMillis |
Der Zeitpunkt, an dem die Inaktivität begann, in Form von Millisekunden seit Epoche |
inactivityDurationMillis |
Die Anzahl der Millisekunden, die die Inaktivität gedauert hat |