大数据Nifi处理器

Posted 赵广陆

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了大数据Nifi处理器相关的知识,希望对你有一定的参考价值。


1 处理器介绍

1.1 查看处理器

1 选择处理器组件

2 弹出窗口显示的就是所有处理器

1.2 常用处理器 - 整理

ExecuteScript : 执行脚本处理器 支持: clojure ecmascript groovy lua python ruby

QueryDatabaseTable : 数据库查询处理器 支持: mysql

ConvertAvroToJSON : avro 数据格式转换为 json

SplitJson : 将JSON文件拆分为多个单独的FlowFiles 用于由JsonPath表达式指定的数组元素。

EvaluateJsonPath : 根据FlowFile的内容评估一个或多个JsonPath表达式。这些表达式的结果将分配给FlowFile属性,或者写入FlowFile本身的内容,具体取决于处理器的配置。

ReplaceText : 文本组装与替换 支持正则表达式

PutHDFS : 将FlowFile数据写入Hadoop分布式文件系统(HDFS)

PutHiveQL : 执行hive ddl/dml命令 如: insert update

PublishKafka_2_0 : 根据配置将消息发送到kafka topic

SelectHiveQL : 执行hive select 语句并获取结果

PutSQL : 执行SQL的insert或update命令

GetFile : 从目录中的文件创建FlowFiles。

PutFile : 将FlowFile数据写入文件

GetHDFS : 从Hadoop分布式文件系统获取文件

CaptureChangeMySQL : 从MySQL数据库中检索更改数据捕获(CDC)事件。CDC事件包括INSERT,UPDATE,DELETE操作。事件作为单个流文件输出,这些文件按操作发生的时间排序。

ExecuteStreamCommand : 一般用于执行sh脚本

更多功能等待去发掘

2 配置处理器

2.1 添加一个处理器

以GetFile为例:

2.2 配置处理器配置项说明

右键()要配置的处理器 会弹出配置项菜单 如下图:

选项说明:

  • Configure(配置):此选项允许用户建立或更改处理器的配置。
  • Start(启动或停止):此选项允许用户启动或停止处理器; 该选项可以是Start或Stop,具体取决于处理器的当前状态。
  • Disable(启用或禁用):此选项允许用户启用或启用处理器; 该选项将为“启用”或“禁用”,具体取决于处理器的当前状态。
  • View data provenance(查看数据来源):此选项显示NiFi数据来源表,其中包含有关通过该处理器路由FlowFiles的数据来源事件的信息。
  • View status history(查看状态历史记录):此选项打开处理器统计信息随时间的图形表示。
  • View usage(查看用法):此选项将用户带到处理器的使用文档。
  • View connection → Upstream(查看连接→上游):此选项允许用户查看和“跳转”入处理器的上游连接。当处理器连接进出其他进程组时,这尤其有用。
  • View connection → Downstream(查看连接→下游):此选项允许用户查看和“跳转”到处理器外的下游连接。当处理器连接进出其他进程组时,这尤其有用。
  • Centere in view(视图中心):此选项将画布的视图置于给定的处理器上。
  • Change color(更改颜色):此选项允许用户更改处理器的颜色,这可以使大流量的可视化管理更容易。
  • Group (添加到组):把当前处理器添加到组
  • Create template(创建模板):此选项允许用户从所选处理器创建模板。
  • Copy(复制):此选项将所选处理器的副本放在剪贴板上,以便可以通过右键单击工作区并选择“粘贴”将其粘贴到工作区上的其他位置。复制粘贴操作也可以使用按键Ctrl-C和Ctrl-V完成。
  • Delete(删除):此选项允许从画布中删除处理器。

2.3 配置处理器

以GetFile为例

方式1: 右键选择 – > Configure

方式2: 鼠标左键双击处理器

配置窗口如下图:

配置分为4个部分: SETTING SCHEDULING PROPERTIES COMMENTS 接下来一一介绍

2.3.1 SETTING ( 设置 )

2.3.2 SCHEDULING ( 任务调度 )

PS: 不同的处理器 可能略有不同

2.3.3 PROPERTIES ( 属性 )

PS: 不同处理属性不同

2.3.4 COMMENTS ( 注释 )

修改完成 记得保存修改 点击右下角的 “APPLY” 保存修改

以上是关于大数据Nifi处理器的主要内容,如果未能解决你的问题,请参考以下文章

大数据NiFi:NiFi集群页面的添加配置处理器操作

大数据NiFi:NiFi集群页面的添加配置处理器操作

大数据NiFi(十六):处理器Connection连接

大数据NiFi:NiFi入门案例一

大数据NiFi:NiFi入门案例一

大数据NiFi(十三):NiFi监控