1. 程式人生 > >吸星大法NiFi——使用NiFi實現檔案同步功能

吸星大法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刪除了,如圖所示:

在這裡插入圖片描述

7 參考

吸星大法NiFi——NiFi下載及安裝

Getting Started with Apache NiFi

【NIFI】 Apache NiFI 安裝及簡單的使用