FetchDistributedMapCache 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Beschreibung¶
Computes cache key(s) from FlowFile attributes, for each incoming FlowFile, and fetches the value(s) from the Distributed Map Cache associated with each key. If configured without a destination attribute, the incoming FlowFile ‚s content is replaced with the binary data received by the Distributed Map Cache. If there is no value stored under that key then the flow file will be routed to‘ not-found ‚. Note that the processor will always attempt to read the entire cached value into memory before placing it in it’s destination. This could be potentially problematic if the cached value is very large.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Cache Entry Identifier |
Eine durch Kommas getrennte Liste von FlowFile-Attributen oder die Ergebnisse von Attribute Expression Language-Anweisungen, die gegen ein FlowFile ausgewertet werden, um den/die Wert(e) zu ermitteln, der/die zur Identifizierung von Duplikaten verwendet wird/werden. Diese Werte werden zwischengespeichert. NOTE: Es ist nur ein einziger „Cache Entry Identifier“ erlaubt, es sei denn, es ist „Put Cache Value In Attribute“ angegeben. Mehrere Cache-Lookups werden nur unterstützt, wenn das Ziel eine Reihe von Attributen ist (weitere Informationen, einschließlich der Namenskonvention, finden Sie in der Dokumentation zu „Put Cache Value In Attribute“). |
Zeichensatz |
Der Zeichensatz, in dem der zwischengespeicherte Wert codiert ist. Dies wird nur beim Routing an ein Attribut verwendet. |
Distributed Cache Service |
Der Controller Service, der zum Abrufen der zwischengespeicherten Werte verwendet wird. |
Max Length To Put In Attribute |
Wenn Sie den Cache-Wert in ein Attribut des FlowFile weiterleiten (indem Sie die Eigenschaft „Put Cache Value In Attribute“ einstellen), wird die Anzahl der Zeichen, die in den Attributwert gesetzt werden, maximal diese Anzahl betragen. Dies ist wichtig, da Attribute im Speicher gehalten werden und große Attribute schnell zu Problemen führen, wenn der Speicher voll ist. Wenn die Ausgabe diesen Wert überschreitet, wird sie entsprechend gekürzt. Erwägen Sie, dies zu verkleinern, sofern möglich. |
Put Cache Value In Attribute |
Wenn diese Option gesetzt ist, wird der empfangene Cache-Wert in ein FlowFile-Attribut anstatt in den Inhalt des theFlowFile eingefügt. Der Attributschlüssel, der gesetzt werden soll, wird durch Auswerten des Werts dieser Eigenschaft bestimmt. Wenn mehrere Cache-Eintragsbezeichner ausgewählt sind, werden mehrere Attribute geschrieben. Dabei wird der ausgewertete Wert dieser Eigenschaft verwendet, an den ein Punkt (.) und der Name des Cache-Eintragsbezeichners angehängt wird. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
Wenn die Kommunikation mit dem Cache nicht möglich ist oder der Cache-Eintrag als leer bewertet wird, wird das FlowFile zurückgestellt und zu dieser Beziehung weitergeleitet. |
not-found |
Wenn der „Cache Entry Identifier“ eines FlowFiles nicht im Cache gefunden wurde, wird es an diese Beziehung weitergeleitet. |
success |
Wenn die Kommunikation mit dem Cache erfolgreich war, wird es an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
user-defined |
Wenn die Eigenschaft „Put Cache Value In Attribute“ festgelegt ist, wird der Wert, auf den sie gesetzt ist, zum Attributschlüssel und der Wert ist die Antwort aus dem verteilten Map-Cache. Wenn mehrere Cache-Eintragsbezeichner ausgewählt sind, werden mehrere Attribute geschrieben. Dabei wird der ausgewertete Wert dieser Eigenschaft verwendet, an den ein Punkt (.) und der Name des Cache-Eintragsbezeichners angehängt wird. Wenn beispielsweise die Eigenschaft „Cache Entry Identifier“ auf „id,name“ gesetzt ist und die benutzerdefinierte Eigenschaft den Namen „fetched“ hat, werden zwei Attribute geschrieben, „fetched.id“ und „fetched.name“, die ihre jeweiligen Werte enthalten. |