如何在apache NIFI中將文本文件轉換爲avro

Question

我們試圖在Nifi中使用ConvertCSVToAvro將文本文件（以逗號分隔）轉換爲avro，但輸出是來自ConvertCSVToAvro處理器的文本文件。

Answer 1

喜饒@Teekoji BeLkAr，

到CSV轉換爲Avro的，

1. 您需要首先爲逐行使用SplitText處理器分裂的文本。
2. 使用正則表達式通過使用ExtractText處理器提取值，它將結果值作爲每個流文件的屬性。
3. ReplaceText處理器將屬性替換爲流文件的內容。
4. InferAvroSchema處理器獲取流文件內容的模式。

5. ConvertCSVToAvro處理器的flowfile內容轉換成的Avro格式 注： -我已經使用管道（|）作爲分隔符在ReplaceText處理器重置價值，只要你喜歡，你可以使用任何分隔符。但分隔符需要與InferAvroSchema CSV標題定義相匹配

   所有用於處理器中的配置中的鏈接所提到的，

https://community.hortonworks.com/questions/131332/nifi-convert-text-file-consisting-of-key-value-pai.html?childToView=131440#answer-131440][1]