ConvertRecord 2025.5.31.15

Bundle

org.apache.nifi | nifi-standard-nar

Beschreibung

Konvertiert Datensätze mithilfe der konfigurierten Controller Services Record Reader- und Record Writer von einem Datenformat in ein anderes. Reader und Writer müssen mit „übereinstimmenden“ Schemas konfiguriert sein. Damit ist gemeint, dass die Schemas dieselben Feldnamen haben müssen. Die Feldtypen müssen nicht identisch sein, wenn ein Feldwert von einem Typ in einen anderen umgewandelt werden kann. Wenn das Eingabeschema beispielsweise ein Feld mit dem Namen „balance“ vom Typ „double“ enthält, kann das Ausgabeschema ein Feld mit dem Namen „balance“ und dem Typ „string“, „double“ oder „float“ enthalten. Wenn ein Feld in der Eingabe vorhanden ist, das in der Ausgabe nicht vorhanden ist, wird das Feld in der Ausgabe ausgelassen. Wenn im Ausgabeschema ein Feld angegeben ist, das in den Eingabedaten/im Eingabeschema nicht vorhanden ist, wird das Feld in der Ausgabe nicht vorhanden sein oder einen Nullwert haben, je nach Writer.

Tags

avro, convert, csv, freeform, generic, json, log, logs, record, schema, text

Eingabeanforderung

REQUIRED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

Include Zero Record FlowFiles

Bei der Konvertierung eines eingehenden FlowFile, wenn die Konvertierung keine Daten ergibt, gibt diese Eigenschaft an, ob ein FlowFile an die entsprechenden Beziehung gesendet werden soll oder nicht

Record Reader

Gibt den Controller Service an, der zum Lesen eingehender Daten verwendet werden soll

Record Writer

Gibt den Controller Service an, der für das Schreiben der Datensätze verwendet werden soll

Beziehungen

Name

Beschreibung

failure

Wenn ein FlowFile nicht vom konfigurierten Eingabeformat in das konfigurierte Ausgabeformat umgewandelt werden kann, wird ein unverändertes FlowFile an diese Beziehung weitergeleitet.

success

FlowFiles, die erfolgreich umgewandelt werden, werden 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.

Anwendungsfälle

Daten von einem datensatzorientierten Format in ein anderes konvertieren