Wie erstelle ich in Nifi eine JSON-Flow-Datei aus einer Liste von Tags und einer Datei, die alle Datensätze enthält, einen Datensatz pro Zeile?

Ich habe eine durch Semikolons getrennte Datei mit 1000 Datensätzen, einen Datensatz pro Zeile, wobei jeder Datensatz mehrere durch Semikolons getrennte Felder enthält. Ich habe auch eine Liste mit Tags für die Felder in den Datensätzen. Wie kombiniere ich diese in NiFi zu einer JSON-Flow-Datei?

Semikolon-getrennte Datendatei:

r1f1;r1f2;r1f3;r1f4;r1f5
r2f1;r2f2;r2f3;r2f4;r2f5
r3f1;f3r2;r3f3;r3f4;r3f5
...

Liste der Feld-Tags:

f1_tag, f2_tag, f3_tag, f4_tag, f5_tag

Ich kann die Liste der Tags in einen Prozessorblock eingeben, bin mir aber nicht sicher, welchen Prozessor ich gegebenenfalls verwenden kann.

Lösung des Problems

Klingt ziemlich einfach. Verwenden Sie ConvertRecordwith CSVReaderals Record Reader(vergessen Sie nicht, es so zu konfigurieren, dass Semikolon als Value Separator! verwendet wird) und setzen Sie Record Writerto be JsonRecordSetWriterund schon haben Sie es!

Vergessen Sie übrigens nicht, eine Kopfzeile hinzuzufügen!