ScriptedValidateRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-scripting-nar

Beschreibung¶

Dieser Prozessor bietet die Möglichkeit, Datensätze in FlowFiles mit dem vom Benutzer bereitgestellten Skript zu überprüfen. Das Skript sollte ein Argument als Eingabe haben und einen booleschen Wert zurückgeben. Anhand dieses Ergebnisses kategorisiert der Prozessor die Datensätze als „gültig“ oder „ungültig“ und leitet sie an die entsprechende im Stapel weiter. Außerdem wird das ursprüngliche FlowFile an die Beziehung „original“ weitergeleitet oder, im Falle einer erfolglosen Verarbeitung, an die Beziehung „failed“.

Tags¶

groovy, record, script, validate

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Module Directory	Durch Kommas getrennte Liste von Pfaden zu Dateien und/oder Verzeichnissen, die vom Skript benötigte Module enthalten.
Record Reader	Der Record Reader zum Parsen des eingehenden FlowFile in Datensätze.
Record Writer	Der Record Writer, der für die Serialisierung von Datensätzen nach deren Transformation verwendet wird
Script Body	Body des auszuführenden Skripts. Es kann nur eine der Optionen „Script File“ oder „Script Body“ verwendet werden
Script Engine	Die für das Skript zu verwendende Sprache
Script File	Pfad zur auszuführenden Skriptdatei. Es kann nur eine der Optionen „Script File“ oder „Script Body“ verwendet werden

Einschränkungen¶

Erforderliche Berechtigung	Erläuterung
execute code	Bietet dem Operator die Möglichkeit, beliebigen Code unter Verwendung aller Berechtigungen von NiFi auszuführen.

Beziehungen¶

Name	Beschreibung
failure	Falls bei der Verarbeitung des eingehenden FlowFile ein Problem auftritt, wird das eingehende FlowFile an diese Beziehung weitergeleitet.
invalid	Ein FlowFile, das die ungültigen Datensätze aus dem eingehenden FlowFile enthält, wird an diese Beziehung weitergeleitet. Wenn es keine ungültigen Datensätze gibt, wird das FlowFile nicht an diese Beziehung weitergeleitet.
original	Nach erfolgreicher Verarbeitung wird das eingehende FlowFile an diese Beziehung übertragen. Dies geschieht unabhängig davon, ob FlowFiles an „gültige“ oder „ungültige“ Beziehungen weitergeleitet wird.
gültig	Das FlowFile, das die gültigen gültigen Datensätze aus dem eingehenden FlowFile enthält, werden an diese Beziehung weitergeleitet. Wenn es keine gültigen Datensätze gibt, wird das FlowFile nicht an diese Beziehung weitergeleitet.

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.
record.error.message	Dieses Attribut gibt im Falle eines Fehlers die Fehlermeldung an, die der Reader oder Writer erhalten hat.