关闭→
当前位置:趣知常识网>游戏数码>互联网>Apache nifi的processor开发过程

Apache nifi的processor开发过程

趣知常识网 人气:5.05K

Apache NiFi 是一个易于使用、功能强大而且可靠的数据处理和分发系统。Apache NiFi 是为数据流设计。它支持高度可配置的指示图的数据路由、转换和系统中介逻辑。nifi可以自己开发扩展插件processor,下面介绍processor的开发过程。

方法/步骤1 创建工程

(01)环境准备,需要安装jdk和maven。通过命令来检查jdkhemaven是否已经安装。

Apache nifi的processor开发过程

(02)开始创建processor工程。创建新的目录,并在目录下执行mvn archetype:generate。根据界面提示输入相应的版本和工程信息。命令执行完成后,就会生成nifi processor工程文件。

Apache nifi的processor开发过程 第2张

方法/步骤2 编写第一个processor

(01)工程生成后,在源码中可以找到一个默认的,可修改此文件来编写自己的第一个processor。

(02)为我的processor添加描述信息,属性,relation已经编写初始化函数。如下图所示:

Apache nifi的processor开发过程 第3张

(03)编写onTrigger函数。也是最重要的函数。这个函数来实现主要的功能。此函数主要分为以下几个内容:读取FlowFile,获取属性设置,写FlowFile提交到Relation。

Apache nifi的processor开发过程 第4张

方法/步骤3 编译并部署

(01)编译,在工程目录下执行mvn install命令。执行成功后,会生成文件。例如我的文件名称为为:。这个文件就是我们要部署的文件

(02)把放到nifi安装目录下的lib目录下。重新启动nifi服务。

(03)在nifi的界面上就可以看到自己编写的第一个processor了。

Apache nifi的processor开发过程 第5张