Apache NIFI：从数据流内容拆分并转换为 Json 属性

【问题标题】：Apache NIFI: From Dataflow Content Splitted and Converted to Json AttributesApache NIFI：从数据流内容拆分并转换为 Json 属性
【发布时间】：2016-09-08 19:38:11
【问题描述】：

我从我的 Apache Kafka 获得了以下流文件内容，我的目标是将这些数据拆分为不同的属性。

例如日期距离等等

然后把这个属性转换成Json（我知道哪个处理器，我需要那个）

但我不知道，我需要哪个 Nifi 处理器来实现拆分功能以及配置应该是什么样子

示例内容

2016-09-08 16:40:32.215|39|11|Jamie Engesser|1594289134|孟菲斯到小石城 Route 2|Normal|40.76|-88.77|1000 取消

【问题讨论】：

标签： apache-nifi

【解决方案1】：

如果每个输入流文件都是单行记录，您可以使用这样的流：

ExtractText - 将单个文本记录提取到属性中。这可能就像使用默认行设置添加带有正则表达式 (.*) 的自定义属性“行”一样简单。
UpdateAttribute - 将单个字段解析为单独的属性。 NiFi 表达式语言中的getDelimitedField 函数在这里很有用。例如，${line:getDelimitedField(1, "|")} 获取日期，${line:getDelimitedField(6, "|")} 获取“Memphis 到 Little Rock Route 2”路线。

【讨论】：