如何在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]