ConsumeBoxEvents 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-box-nar
Beschreibung¶
Verarbeitet alle Ereignisse von Box. Dieser Prozessor kann verwendet werden, um Ereignisse wie Uploads, Änderungen, Löschungen usw. zu erfassen. Der Inhalt der Ereignisse wird als JSON-Array an die Beziehung „success“ gesendet. Ereignisse können bei einem Neustart von NiFi oder bei Überschreitung der Warteschlangenkapazität gelöscht werden. Die letzte bekannte Position des Box-Streams wird im Prozessorstatus gespeichert und wird verwendet, um den Stream beim Neustart des Prozessors an der letzten bekannten Position fortzusetzen.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Queue Capacity |
Die maximale Größe der internen Warteschlange, die zum Puffern von Ereignissen verwendet wird, die vom zugrunde liegenden Stream an den Prozessor übertragen werden. Wird dieser Wert erhöht, können bei plötzlichem Anstieg der Meldungen mehr Meldungen im Speicher gepuffert werden, allerdings steigt dadurch auch der gesamte Speicherverbrauch des Prozessors während solcher Spitzen. |
box-client-service |
Controller Service, der verwendet wird, um eine Box-API-Verbindung zu erhalten. |
Statusmanagement¶
Bereiche |
Beschreibung |
|---|---|
CLUSTER |
Die letzte bekannte Position des Box-Streams wird im Prozessorstatus gespeichert und dient dazu, den Stream beim Neustart des Prozessors von der letzten bekannten Position aus fortzusetzen. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
Erfolgreich empfangene Ereignisse werden an diede Beziehung gesendet. |