Apache Nifi 简明教程

Apache NiFi - Custom Processor

Apache NiFi 是一个开源平台，为开发者提供了在 NiFi 库中添加其定制处理器的选项。按照这些步骤创建自定义处理器。

  1. 从下面给出的链接下载 Maven 最新版本。 https://maven.apache.org/download.cgi

  2. 添加一个环境变量名为 M2_HOME，并将其值设置为 Maven 的安装目录。

  3. 从以下链接下载 Eclipse IDE。 https://www.eclipse.org/downloads/download.php

  4. 打开命令提示符并执行 Maven Archetype 命令。

> mvn archetype:generate

  1. 在原型项目中搜索 nifi 类型。

  2. Select org.apache.nifi:nifi-processor-bundle-archetype project.

  3. 然后从版本列表中选择最新版本，针对本教程，即 1.7.1。

  4. 输入groupId、artifactId、version、package和artifactBaseName等。

  5. 然后将创建一个具有两个目录的maven项目。nifi-<artifactBaseName>-processors nifi-<artifactBaseName>-nar

  6. 在nifi-<artifactBaseName>-processors目录中运行以下命令，以在eclipse中添加该项目。

mvn install eclipse:eclipse

  1. 打开 Eclipse，然后从文件菜单中选择导入。

  2. 然后选择“将现有项目添加到工作空间”，并从eclipse中的nifi-<artifactBaseName>-processors目录添加该项目。

  3. 在 public void onTrigger(ProcessContext context, ProcessSession session) 函数中添加你的代码，该函数在计划运行处理器时运行。

  4. 然后通过运行下面提到的命令将代码打包到NAR文件中。

mvn clean install

  1. 将在nifi—​nar/target目录中创建一个NAR文件。

  2. 将NAR文件复制到Apache NiFi的lib文件夹并重新启动NiFi。

  3. 在 NiFi 成功重新启动后，检查处理器列表以查找新的自定义处理器。

  4. 对于任何错误，请检查./logs/nifi.log文件。