吸星大法NiFi——使用NiFi實現檔案同步功能
轉載請註明出處:http://blog.csdn.net/dongdong9223/article/details/84940992
本文出自【我是幹勾魚的部落格】
Ingredients:
之前在吸星大法NiFi——NiFi下載及安裝中講述了NiFi搭建的方法,今天使用NiFi實現一個簡單的操作:磁碟檔案同步。
我們要做的是,原資料夾:
/opt/tmp/ninf/input/
有一個檔案file.txt:
[email protected]********************:/opt/tmp/nifi/input# ls -al
total 12
drwxr-xr-x 2 root root 4096 Dec 10 21:55 .
drwxr-xr-x 4 root root 4096 Dec 7 22:36 …
-rw-r–r-- 1 root root 14 Dec 10 21:55 file.txt
其內容為:
Hello world!
要使用NiFi將其移動到目標資料夾:
/opt/tmp/ninf/output/
並且保留原始檔夾中的原始檔。
1 建立GetFile Processor
從工具欄中拖入一個Processor,如圖所示:
在彈出面板中搜索GetFIle,然後確認,如圖所示:
雙擊Processor,彈出配置資訊,如圖所示:
2 建立PutFile Processor
同樣再拖入一個Processor,搜尋“PutFile”,如圖所示:
雙擊Processor,彈出配置資訊,如圖所示:
3 建立Connection
此時這2個Processor如圖所示:
拖拽GetFile的箭頭到PutFile,上圖所示,此時會彈出Create Connection,如下圖所示:
此時如圖:
4 執行Processor
同時選中2個Processor,然後右鍵選擇Start,如圖所示:
能夠看到目標資料夾出現了檔案:
[email protected]*********************:/opt/tmp/nifi/input# ls -al …/output/
total 12
drwxr-xr-x 2 root root 4096 Dec 10 22:12 .
drwxr-xr-x 4 root root 4096 Dec 7 22:36 …
-rw-r–r-- 1 root root 13 Dec 10 22:12 file.txt
5 停止Processor
右鍵Stop即可將其停止。
6 刪除Processor
注意,如果想刪除Processor,先要右鍵對Connection設定“Empty queue”,並將其刪除;然後就可以右鍵將Processor刪除了,如圖所示: