Apache nifi的processor开发过程
Apache NiFi 是一个易于使用、功能强大而且可靠的数据处理和分发系统。Apache NiFi 是为数据流设计。它支持高度可配置的指示图的数据路由、转换和系统中介逻辑。nifi可以自己开发扩展插件processor，下面介绍processor的开发过程。
方法/步骤1 创建工程
- 01
环境准备，需要安装jdk和maven。通过命令来检查jdkhemaven是否已经安装。
- 02
开始创建processor工程。 创建新的目录，并在目录下执行mvn archetype:generate。根据界面提示输入相应的版本和工程信息。命令执行完成后，就会生成nifi processor工程文件。
方法/步骤2 编写第一个processor
- 01
工程生成后，在源码中可以找到一个默认的MyProcessor.java，可修改此文件来编写自己的第一个processor。
- 02
为我的processor添加描述信息，属性，relation已经编写初始化函数。如下图所示：
- 03
编写onTrigger函数。也是最重要的函数。这个函数来实现主要的功能。此函数主要分为以下几个内容： 读取FlowFile，获取属性设置，写FlowFile提交到Relation。
方法/步骤3 编译并部署
- 01
编译，在工程目录下执行mvn install命令。执行成功后，会生成.nar文件。例如我的文件名称为为：nifi-demo-nar-1.0-SNAPSHOT.nar。这个文件就是我们要部署的文件
- 02
把nifi-demo-nar-1.0-SNAPSHOT.nar放到nifi安装目录下的lib目录下。重新启动nifi服务。
- 03
在nifi的界面上就可以看到自己编写的第一个processor了。
赞 (0)