nifi

安装

使用https

注意

需要关闭代理

nifi.web.https.host=0.0.0.0

bin/nifi.sh set-single-user-credentials admin 123456123456

bin/nifi.sh restart

• 使用http

警告

先启动后再停止，然后进行修改

bin/nifi.sh start

修改 nifi.properties 文件

nifi.remote.input.secure=false

nifi.web.http.host=10.200.10.21
nifi.web.http.port=7788

nifi.web.https.host=
nifi.web.https.port=

使用

删除管道需要上下游processor都停止

变量

python 脚本

processor ExecuteStreamCommand

import sys
import json

# 从标准输入读取FlowFile内容
data = sys.stdin.read()

# 处理数据
processed_data = data.upper()  # 示例处理

# 输出处理后的结果（会成为新的FlowFile内容）
print(processed_data)

表达式

JsonPath expression
NiFi Expression

Processors

数据清洗

SplitJson

Input Port & Output port

用来连接ProcessGroup

导出和导入flow definition

说明

Properties ——每个Processor内置的配置
Dynamic Properties ——每个Processor允许用户自定义的属性

案例

• EvaluateJsonPath

写入数据库

convertjsontosql -> putsql