- Apache NiFi 教程
- Apache NiFi - 首页
- Apache NiFi - 简介
- Apache NiFi - 基本概念
- Apache NiFi - 环境设置
- Apache NiFi - 用户界面
- Apache NiFi - 处理器
- Apache NiFi - 处理器分类
- Apache NiFi - 处理器关系
- Apache NiFi - FlowFile
- Apache NiFi - 队列
- Apache NiFi - 处理组
- Apache NiFi - 标签
- Apache NiFi - 配置
- Apache NiFi - 管理
- Apache NiFi - 创建流程
- Apache NiFi - 模板
- Apache NiFi - API
- Apache NiFi - 数据溯源
- Apache NiFi - 监控
- Apache NiFi - 升级
- Apache NiFi - 远程处理组
- Apache NiFi - 控制器设置
- Apache NiFi - 报告任务
- Apache NiFi - 自定义处理器
- Apache NiFi - 自定义控制器服务
- Apache NiFi - 日志
- Apache NiFi 有用资源
- Apache NiFi - 快速指南
- Apache NiFi - 有用资源
- Apache NiFi - 讨论
Apache NiFi - 自定义处理器
Apache NiFi 是一个开源平台,允许开发者向 NiFi 库添加自定义处理器。请按照以下步骤创建自定义处理器。
从以下链接下载最新版本的 Maven。
添加名为 M2_HOME 的环境变量,并将值设置为 Maven 的安装目录。
从以下链接下载 Eclipse IDE。
打开命令提示符并执行 Maven Archetype 命令。
> 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 文件。