📜  Apache NiFi-处理器分类

📅  最后修改于: 2020-11-18 08:40:59             🧑  作者: Mango


在本章中,我们将讨论Apache NiFi中的进程分类。

数据提取处理器

数据提取类别下的处理器用于将数据提取到NiFi数据流中。这些主要是apache NiFi中任何数据流的起点。属于这些类别的一些处理器是GetFile,GetHTTP,GetFTP,GetKAFKA等。

路由和中介处理器

路由和中介处理器用于根据流文件的属性或内容中的信息将流文件路由到不同的处理器或数据流。这些处理器还负责控制NiFi数据流。属于此类别的一些处理器是RouteOnAttribute,RouteOnContent,ControlRate,RouteText等。

数据库访问处理器

此数据库访问类别的处理器能够从数据库中选择或插入数据,或者执行和准备其他SQL语句。这些处理器主要使用Apache NiFi的数据连接池控制器设置。属于此类别的一些处理器是ExecuteSQL,PutSQL,PutDatabaseRecord,ListDatabaseTables等。

属性提取处理器

属性提取处理器负责在NiFi数据流中提取,分析,更改流文件属性处理。属于此类别的一些处理器是UpdateAttribute,EvaluateJSONPath,ExtractText,AttributesToJSON等。

系统交互处理器

系统交互处理器用于在任何操作系统中运行进程或命令。这些处理器还以多种语言运行脚本以与各种系统进行交互。属于此类别的一些处理器是ExecuteScript,ExecuteProcess,ExecuteGroovyScript,ExecuteStreamCommand等。

数据转换处理器

属于数据转换的处理器能够更改流文件的内容。当用户必须将流文件作为HTTP正文发送以调用HTTP处理器时,这些文件可用于完全替换流文件的数据。属于此类别的一些处理器是ReplaceText,JoltTransformJSON等。

发送数据处理器

发送数据处理器通常是数据流中的最终处理器。这些处理器负责存储数据或将数据发送到目标服务器。成功存储或发送数据后,这些处理器将丢弃具有成功关系的流文件。属于此类别的一些处理器是PutEmail,PutKafka,PutSFTP,PutFile,PutFTP等。

拆分和汇总处理器

这些处理器用于拆分和合并流文件中存在的内容。属于该类别的一些处理器是SplitText,SplitJson,SplitXml,MergeContent,SplitContent等。

HTTP处理器

这些处理器处理HTTP和HTTPS调用。属于此类别的一些处理器是InvokeHTTP,PostHTTP,ListenHTTP等。

AWS处理器

AWS处理器负责与Amazon Web Services系统进行交互。属于该类别的一些处理器是GetSQS,PutSNS,PutS3Object,FetchS3Object等。