Notify 2025.10.2.19

Bundle

org.apache.nifi | nifi-standard-nar

Beschreibung

Caches a release signal identifier in the distributed cache, optionally along with the FlowFile’s attributes. Any flow files held at a corresponding Wait processor will be released once this signal in the cache is discovered.

Tags

cache, distributed, map, notify, release, signal

Eingabeanforderung

REQUIRED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

attribute-cache-regex

Any attributes whose names match this regex will be stored in the distributed cache to be copied to any FlowFiles released from a corresponding Wait processor. Note that the uuid attribute will not be cached regardless of this value. If blank, no attributes will be cached.

distributed-cache-service

Der Controller Service, der zum Zwischenspeichern von Freigabesignalen verwendet wird, um Dateien freizugeben, die bei einem entsprechenden Wait-Prozessor in der Warteschlange stehen

release-signal-id

Ein Wert oder das Ergebnis einer Attribute Expression Language-Anweisung, der anhand eines FlowFile ausgewertet wird, um den Release-Signal-Cache-Schlüssel zu bestimmen.

signal-buffer-count

Geben Sie die maximale Anzahl der eingehenden FlowFiles an, die gepuffert werden können, bis Signale an den Cache-Dienst gemeldet werden. Je mehr Puffer zur Verfügung stehen, desto besser ist die Leistung, da die Anzahl der Interaktionen mit dem Cache-Dienst reduziert wird, indem Signale anhand ihrer Signal-ID gruppiert werden, wenn mehrere eingehende Flow-Dateien dieselbe Signal-ID haben.

signal-counter-delta

Ein Wert oder das Ergebnis einer Anweisung der Attribute Expression Language, der anhand eines FlowFile ausgewertet wird, um den Signalzähler-Deltawert zu bestimmen. Geben Sie an, um wie viel der Zähler steigen soll. Wenn z. B. mehrere Signalereignisse im Batch verarbeitet werden, kann die Anzahl der verarbeiteten Ereignisse mit dieser Eigenschaft auf einmal mitgeteilt werden. Null (0) hat eine besondere Bedeutung: Der Zähler wird auf 0 zurückgesetzt, was besonders nützlich ist, wenn dieser Modus zusammen mit „Wait Releasable FlowFile Count = Zero (0)“ verwendet wird, um eine „Öffnen-Schließen-Gate”-Flusskontrolle zu ermöglichen. Einer (1) kann einen entsprechenden Wait-Prozessor öffnen, und Null (0) kann ihn negieren, als würde man ein Gate schließen.

signal-counter-name

Ein Wert oder das Ergebnis einer Anweisung der Attribute Expression Language, der anhand eines FlowFile ausgewertet wird, um den Namen des Signalzählers zu ermitteln. Der Name des Signalzählers ist nützlich, wenn ein entsprechender Warteprozessor die Anzahl der Vorkommen verschiedener Ereignistypen kennen muss, z. B. Erfolg oder Fehlschlagen oder Namen der Zieldatenquellen usw.

Beziehungen

Name

Beschreibung

failure

Wenn der Cache nicht erreicht werden kann oder wenn der Bezeichner für das Freigabesignal null oder leer ist, wird FlowFiles an diese Beziehung weitergeleitet.

success

Alle FlowFiles, bei denen das Freigabesignal erfolgreich in den Cache eingegeben wurde, werden an diese Beziehung weitergeleitet.

Schreibt Attribute

Name

Beschreibung

notified

Alle FlowFiles erhalten ein Attribut „notified“. Der Wert dieses Attributs ist „true“, wenn das FlowFile benachrichtigt wird, andernfalls „false“.

Siehe auch: