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.

Tags¶

active, activity, detection, flow, inactive, monitor

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	Geben Sie an, wie die Aktivität des Ablaufs bestimmt werden soll. „Knoten“ bedeutet, dass die Aktivität bei jedem einzelnen Knoten separat untersucht wird. Dies kann nützlich sein, wenn DFM erwartet, dass jeder Knoten verteilt Ablaufdateien empfangen sollte. Mit „cluster“ wird definiert, dass der Ablauf aktiv ist, wenn mindestens ein Knoten aktiv Ablaufdateien empfängt. Wenn NiFi im eigenständigen Modus ausgeführt wird, sollte dies als „node“ eingestellt werden, wenn es „cluster“ ist, protokolliert NiFi eine Warnmeldung und fungiert als „node“-Bereich.
Reporting Node	Geben Sie an, welcher Knoten Benachrichtigungs-Flowfiles an inaktive und wiederhergestellte Beziehungen senden soll. Bei „all“ sendet jeder Knoten in diesem Cluster Flowfiles für Benachrichtigungen. „primary“ bedeutet, dass Flowfiles nur von einem Primärknoten gesendet werden. Wenn NiFi im eigenständigen Modus ausgeführt wird, sollte dies auf „all“ gesetzt werden, auch wenn es „primary“ ist. NiFi fungiert als‘ 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