ScriptedPartitionRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-scripting-nar
Beschreibung¶
Empfängt datensatzorientierte Daten (d. h. Daten, die vom konfigurierten Record Reader gelesen werden können) und wertet das vom Benutzer bereitgestellte Skript für jeden Datensatz im eingehenden FlowFile aus. Jeder Datensatz wird dann mit anderen Datensätzen gruppiert, die sich dieselbe Partition teilen, und für jede Gruppe von Datensätzen wird ein FlowFile erstellt. Zwei Datensätze teilen sich die gleiche Partition, wenn die Auswertung des Skripts für beide den gleichen Rückgabewert ergibt. Diese werden als Teil derselben Partition betrachtet.
Eingabeanforderung¶
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 |
Wenn ein FlowFile nicht vom konfigurierten Eingabeformat in das konfigurierte Ausgabeformat partitioniert werden kann, wird das unveränderte FlowFile an diese Beziehung weitergeleitet. |
original |
Sobald alle Datensätze in einem eingehenden FlowFile partitioniert wurden, wird das Original-FlowFile an diese Beziehung weitergeleitet. |
success |
FlowFiles, die erfolgreich partitioniert wurden, werden an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
---|---|
partition |
Die Partition des ausgehenden FlowFile. Wenn das Skript angibt, dass die Partition einen Nullwert hat, wird das Attribut auf die Zeichenfolge „<null partition>“ (ohne Anführungszeichen) gesetzt. Andernfalls wird das Attribut auf die Zeichenfolgenrepräsentation des vom Skript zurückgegebenen Werts gesetzt. |
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. |
fragment.index |
Eine aufsteigende Nummer, die die Reihenfolge der partitionierten FlowFiles angibt, die aus einem einzigen übergeordneten FlowFile erstellt wurden. |
fragment.count |
Die Anzahl der partitionierten FlowFiles, die aus dem übergeordneten FlowFile generiert werden. |