Apache NiFi - 自定义处理器



Apache NiFi 是一个开源平台,允许开发者向 NiFi 库添加自定义处理器。请按照以下步骤创建自定义处理器。

> mvn archetype:generate
  • 在原型项目中搜索 nifi 类型。

  • 选择 org.apache.nifi:nifi-processor-bundle-archetype 项目。

  • 然后从版本列表中选择最新版本,本教程使用 1.7.1。

  • 输入 groupId、artifactId、version、package 和 artifactBaseName 等。

  • 然后将创建一个包含两个目录的 Maven 项目。

    • nifi-<artifactBaseName>-processors

    • nifi-<artifactBaseName>-nar

  • 在 nifi-<artifactBaseName>-processors 目录中运行以下命令,将项目添加到 Eclipse 中。

mvn install eclipse:eclipse
  • 打开 Eclipse 并从文件菜单中选择导入。

  • 然后选择“将现有项目导入工作区”,并将项目从 nifi-<artifactBaseName>-processors 目录添加到 Eclipse 中。

  • 在 public void onTrigger(ProcessContext context, ProcessSession session) 函数中添加您的代码,该函数在每次调度处理器运行时都会运行。

  • 然后通过运行以下命令将代码打包到 NAR 文件中。

mvn clean install
  • NAR 文件将创建在 nifi--nar/target 目录中。

  • 将 NAR 文件复制到 Apache NiFi 的 lib 文件夹并重启 NiFi。

  • NiFi 成功重启后,检查处理器列表中是否有新的自定义处理器。

  • 如有任何错误,请检查 ./logs/nifi.log 文件。

广告