nifi自定义processor步骤

女爷i 2022-03-26 14:44 531阅读 0赞

### nifi自定义processor步骤 ###

*  软件依赖
 *  开发步骤
 *   *  创建目录
     *  创建项目骨架
     *  修改逻辑
 *  测试步骤
 *   *  打包
     *  上传
     *  重启

# 软件依赖 #

1.  jdk
2.  maven
3.  Linux Shell客户端及文件上传工具

# 开发步骤 #

## 创建目录 ##

创建目录如`D:/nifi/self-define`，并进入该目录，在地址栏输入cmd进入命令行界面

## 创建项目骨架 ##

执行`mvn archetype:generate`  
但是此时可能会有问题，因为出来的可能只有10中选项，其中并没有关于nifi的  
发现是插件版本问题，使用指定插件版本的命令即可  
`mvn org.apache.maven.plugins:maven-archetype-plugin:2.4:generate`  
\`\`中的内容为填写内容

Choose a number or apply filter (format: [groupId:]artifactId, case sensitive contains): 1311: `nifi`
    # 此处需判断要创建processor还是service项目，区别选择1或2
    Choose archetype:
    1: remote -> org.apache.nifi:nifi-processor-bundle-archetype (-)
    2: remote -> org.apache.nifi:nifi-service-bundle-archetype (-)
    Choose a number or apply filter (format: [groupId:]artifactId, case sensitive contains): : `1`
    # 此处判断对应nifi的版本号，选择相应的数字
    Choose a number: 30: 24
    Define value for property 'groupId': : `first`
    Define value for property 'artifactId': : `first-processor`
    Define value for property 'version':  1.0-SNAPSHOT: : `1.0`
    Define value for property 'artifactBaseName': : `demo`
    Define value for property 'package':  first.processors.demo: :
    [INFO] Using property: nifiVersion = 1.3.0
    Confirm properties configuration:
    groupId: first
    artifactId: first-processor
    version: 1.0
    artifactBaseName: demo
    package: first.processors.demo
    nifiVersion: 1.3.0
     Y: : `Y`

完成创建

## 修改逻辑 ##

修改 `/first-processors/nifi-demo-processors/src/main/java/first/processors/demo/MyProcessor.java`为自己的逻辑，开发完成

# 测试步骤 #

## 打包 ##

进入目录`D:/nifi/self-define`，在地址栏输入cmd进入命令行界面，并执行`mvn clean install`

## 上传 ##

处理成功后找到`[INFO] Installing D:\ideaSpace\nifi-1.3.0\self-define\first-processors\nifi-demo-nar\target\nifi-demo-nar-1.0.nar to D:\SoftWares\apache-maven-3.2.3\repo\first\nifi-demo-nar\1.0\nifi-demo-nar-1.0.nar`中的`nifi-demo-nar-1.0.nar`，并将nar包上传至nifi服务器的lib目录下

## 重启 ##

重启对应的nifi服务`bin/nifi.sh restart`，进入web界面查看并使用自定义的nifi组件