![](https://img-blog.csdnimg.cn/7df3c0ea550849b4b03ab37f0b14ee02.png)
![](https://img-blog.csdnimg.cn/f14a28f3c3dd485ab2ee51b6a2983944.png)
官方文档: Apache NiFi
运行: %HOME%/bin/run-nifi.bat
打开网页:127.0.0.1/nifi
账号密码:%HOME%/logs/nifi-app.log 找到如下字段
![](https://img-blog.csdnimg.cn/db9de5914c884573964db62c39d382dd.png)
开始界面
![](https://img-blog.csdnimg.cn/c6a61a55a354441db3c290ba575f3d57.png)
简单实例
1.本地-> 本地
![](https://img-blog.csdnimg.cn/1486930e3f154d3aa08100a129a92f36.png)
2.SQL实例
![](https://img-blog.csdnimg.cn/0c4645a0502a459b87baf828cfa7d769.png)
注1:可以将流文件发送到各个目标地,以此例,分别发送到了SFTP、本地、Email
新版本ExecuteSQLRecord Processor直接从SQL生成目标数据格式,不需要处理avro等复杂数据结构,节省了很多processor,如下
![](https://img-blog.csdnimg.cn/61a985ccd57c4b1d9ed7c0661985c612.png)
具体文件Attr修改,写法看文档
![](https://img-blog.csdnimg.cn/271c1f7bf04d4ecda110e22e7e72b33a.png)
![](https://img-blog.csdnimg.cn/5a8a2c303e194af1b9c70db4717c83f4.png)
![](https://img-blog.csdnimg.cn/898dcc1447154d8caac07cdb5eb02bd6.png)
![](https://img-blog.csdnimg.cn/fdfe2547f9474590b6ebcf8ed2104479.png)
实例3 csv文件 -> SQL
同样,使用record Processor直接将csv写入sql,要求csv表头和sql完全一致,数据类型不符合会报错
![](https://img-blog.csdnimg.cn/c035bfcfd7b443f79b6a143e97d45c57.png)
![](https://img-blog.csdnimg.cn/23390318eec54f20b8c1ad420b730d11.png)
![](https://img-blog.csdnimg.cn/f5eae41e85e64d61bf583f8fcdcd4dc1.png)