ExtractRecordSchema 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Extrahiert das Datensatzschema aus dem FlowFile mithilfe des mitgelieferten Record Reader und schreibt es in das Attribut avro.schema.

Tags¶

avro, csv, freeform, generic, json, record, schema, text, xml

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
cache-size	Gibt die Anzahl der Schemas an, die zwischengespeichert werden sollen. Dieser Wert sollte die erwartete Anzahl der verschiedenen Schemas widerspiegeln, die im eingehenden FlowFiles enthalten sein können. Dies sorgt für einen effizienteren Abruf der Schemas und damit für eine bessere Prozessorleistung.
record-reader	Gibt den Controller Service an, der zum Lesen eingehender Daten verwendet werden soll

Beziehungen¶

Name	Beschreibung
failure	Wenn das Datensatzschema eines FlowFile nicht aus dem konfigurierten Eingabeformat extrahiert werden kann, wird das FlowFile an diese Beziehung weitergeleitet.
success	FlowFiles, deren Datensatzschemas erfolgreich extrahiert wurden, werden an diese Beziehung weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
record.error.message	Dieses Attribut gibt im Falle eines Fehlers die Fehlermeldung an, die der Reader erhalten hat.
avro.schema	Dieses Attribut liefert das Schema, das unter Verwendung des bereitgestellten FlowFile aus dem Eingabe-RecordReader extrahiert wurde.