Apache Nifi
2.3 NiFi Processor应用介绍
对于NiFi的使用者来说,如果想要创建一个高效的数据流,那么就需要了解什么样的单元处理器才最适合这个数据流。NiFi拥有大量的可以用于各种业务场景的单元处理器可供使用者挑选和使用,这些单元处理器主要提供例如系统之间数据的传输,数据的路由,数据的转换、处理、分割和聚合等大类的功能。
在每个NiFi的版本发布中都会有大量的新的处理器单元产生,这就导致本书中讲重点介绍1.4.0版本及之前的常用处理器单元的功能,我们讲根据这些常用的处理器单元的不同用处进行分类。
2.3.1 数据转换类处理器单元
CompressContent
对于NiFi的使用者来说,如果想要创建一个高效的数据流,那么就需要了解什么样的单元处理器才最适合这个数据流。NiFi拥有大量的可以用于各种业务场景的单元处理器可供使用者挑选和使用,这些单元处理器主要提供例如系统之间数据的传输,数据的路由,数据的转换、处理、分割和聚合等大类的功能。
在每个NiFi的版本发布中都会有大量的新的处理器单元产生,这就导致本书中讲重点介绍1.4.0版本及之前的常用处理器单元的功能,我们讲根据这些常用的处理器单元的不同用处进行分类。
2.3.1 数据转换类处理器单元
CompressContent
CompressContent处理器单元主要用途是对NiFi数据流的FlowFile的内容进行压缩和解压缩,支持的压缩种类如图
ConvertCharacterSet
ConvertCharacterSet处理器单元主要用途将NiFi数据流的FlowFile的内容从一种字符集转换成另外一种字符集。配置例子如图
EncryptContent
EncryptContent处理器单元主要用途将NiFi数据流的FlowFile的内容进行加密/解密传输。
ReplaceText
ReplaceText处理器单元主要用途是根据处理器属性配置的正则表达式对FlowFile的内容进行匹配,如果匹配成功将会降匹配成功的字段替换为配置属性中的字段。将FlowFile的内容全部替换为nifi的配置例子如图