LookupRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Extrahiert ein Feld oder mehrere Felder aus einem Datensatz und sucht in einem LookupService nach einem Wert für diese Felder. Wenn ein Ergebnis vom LookupService zurückgegeben wird, wird dieses Ergebnis optional zum Datensatz hinzugefügt. In diesem Fall fungiert der Prozessor als Anreicherungsprozessor. Unabhängig davon wird der Datensatz dann entweder an die Beziehung „matched“ oder an die Beziehung „unmatched“ weitergeleitet (wenn die Eigenschaft „Routing-Strategy“ so konfiguriert ist), wobei angegeben wird, ob ein Ergebnis vom LookupService zurückgegeben wurde oder nicht, so-dass der Prozessor auch als Routing-Prozessor fungieren kann. Die „Koordinaten“, die für die Suche nach einem Wert im Lookup-Service verwendet werden sollen, werden durch Hinzufügen einer benutzerdefinierten Eigenschaft definiert. Für jede hinzugefügte Eigenschaft wird ein Eintrag zu einer Map hinzugefügt, wobei der Name der Eigenschaft zum Map-Schlüssel und der vom RecordPath zurückgegebene Wert zum Wert für diesen Schlüssel wird. Wenn mehrere Werte vom RecordPath zurückgegeben werden, wird der Datensatz an die Beziehung „unmatched“ weitergeleitet (oder an die Beziehung „success“, je nach Konfiguration der Eigenschaft „Routing Strategy“). Wenn ein oder mehrere Felder mit dem Ergebnis RecordPath übereinstimmen, werden alle übereinstimmenden Felder aktualisiert. Wenn es keine Übereinstimmung im konfigurierten LookupService gibt, werden keine Felder aktualisiert. Das heißt, dass ein vorhandener Wert im Datensatz nicht mit einem Nullwert überschrieben wird. Beachten Sie jedoch, dass, wenn die vom LookupService zurückgegebenen Ergebnisse nicht in Ihrem Schema berücksichtigt werden (genauer gesagt, in dem Schema, das für Ihren Record Writer konfiguriert ist), die Felder nicht in das FlowFile geschrieben werden.

Tags¶

avro, convert, csv, database, db, enrichment, filter, json, logs, lookup, record, route

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Root Record Path	Ein RecordPath, der auf einen untergeordneten Datensatz innerhalb eines jeden Datensatzes der obersten Ebene im FlowFile verweist. Falls angegeben, werden die zusätzlichen Eigenschaften von RecordPath für diesen untergeordneten Datensatz und nicht für den übergeordneten Datensatz ausgewertet. So können Sie die Anreicherung für mehrere untergeordnete Datensätze innerhalb eines einzigen übergeordneten Datensatzes durchführen.
lookup-service	Der Nachschlagedienst, der verwendet werden soll, um einen Wert in jedem Datensatz zu suchen
record-path-lookup-miss-result-cache-size	Gibt an, wie viele Suchwerte/Datensätze zwischengespeichert werden sollen. Wenn diese Eigenschaft auf Null gesetzt ist, wird keine Zwischenspeicherung durchgeführt und die Tabelle wird für jeden Suchwert in jedem Datensatz abgefragt. Wenn sich die Nachschlagetabelle häufig ändert oder die neuesten Daten abgerufen werden müssen, sollten Sie den Cache nicht verwenden.
record-reader	Gibt den Controller Service an, der zum Lesen eingehender Daten verwendet werden soll
record-update-strategy	Diese Eigenschaft definiert die Strategie, die bei der Aktualisierung des Datensatzes mit dem vom Lookup-Service zurückgegebenen Wert verwendet werden soll.
record-writer	Gibt den Controller Service an, der für das Schreiben der Datensätze verwendet werden soll
result-contents	Wenn ein Ergebnis erhalten wird, das einen Datensatz enthält, bestimmt diese Eigenschaft, ob der Datensatz selbst an den konfigurierten Pfad eingefügt wird oder ob der Inhalt des Datensatzes (d. h. die Unterfelder) an den konfigurierten Pfad eingefügt wird.
result-record-path	Ein RecordPath, der auf das Feld verweist, dessen Wert mit dem vom Lookup-Service zurückgegebenen Wert aktualisiert werden soll. Wenn nicht angegeben, wird der vom Nachschlagedienst zurückgegebene Wert ignoriert, außer um zu bestimmen, ob das FlowFile an die Beziehung „matched“ oder die Beziehung „unmatched“ weitergeleitet werden soll.
routing-strategy	Legt fest, wie Datensätze nach Abschluss einer Suche weitergeleitet werden sollen.

Beziehungen¶

Name	Beschreibung
failure	Wenn ein FlowFile nicht angereichert werden kann, wird das unveränderte FlowFile an diese Beziehung weitergeleitet.
success	Alle Datensätze werden an diese Beziehung gesendet, wenn dies so konfiguriert ist, es sei denn, es tritt ein Fehler auf.

Schreibt Attribute¶

Name	Beschreibung
mime.type	Setzt das Attribut „mime.type“ auf den vom Record Writer angegebenen MIME-Typ
record.count	Die Anzahl der Datensätze im FlowFile