1. 通過Ambari QuickLink打開Nifi UI

2. 創(chuàng)建ProcessorGroup
a. 拖動頁面上方工具條中的ProcessorGroup圖標(biāo)至繪圖區(qū)
b. 命名Group并雙擊打開

3.創(chuàng)建Overall flow
1)添加GetFile Processor
a.拖動頁面上方工具條中的Processor圖標(biāo)至繪圖區(qū)可以開始創(chuàng)建數(shù)據(jù)流,成功后如圖

b.在搜索框處輸入想要添加的Processor。此處輸入GetFile,然后點(diǎn)擊Add,GetFile Processor 添加成功。

c.雙擊GetFile處理器或者右擊選擇Configure進(jìn)行配置,根據(jù)自身環(huán)境和需求,填寫相關(guān)配置。然后點(diǎn)擊APPLY。

2)添加PutHive Processor
a.同理添加PutHive,并做相應(yīng)的配置。與GutFile不同的是,此處要創(chuàng)建Reader/Writer。

b)Reader/Writer等相關(guān)配置如下


insurance_schema




c)如圖,點(diǎn)擊右邊的設(shè)置按鈕可以進(jìn)入配置,點(diǎn)擊閃電樣式的按鈕可以啟動。

d)至此,PutHive Processor創(chuàng)建添加成功。
3)連接兩個(gè)Processor
a.每個(gè)處理器都有一組定義的“關(guān)系”,最基本的是success和failure。把鼠標(biāo)停在GetFile Processor,會看到一個(gè)箭頭,拖動箭頭到PutHive ,顯示success即可。

b.此時(shí),PutHive上仍顯示警告,提示為success、retry和failure關(guān)系未連接到其他組件和自動終止??梢杂覔鬰onfigure,在setting中勾選中success、retry和failure即可實(shí)現(xiàn)自動終止。
4.啟動Processor
a.依次啟動Processor,一般按從后往前的順序右擊選擇start。
b.運(yùn)行成功后,可以看到數(shù)據(jù)再不同位置的轉(zhuǎn)移以及數(shù)據(jù)流的大小、時(shí)間等。NiFi為back?pressure提供了兩個(gè)配置元件。分別對應(yīng)的是對象數(shù)量和數(shù)據(jù)大小。并且進(jìn)度條基于隊(duì)列百分比改變顏色:綠色(0-60%),黃色(61-85%)和紅色(86-100%)。鼠標(biāo)懸停在上面可以顯示精確的百分比。
c.當(dāng)運(yùn)行出現(xiàn)問題時(shí),右上角會出現(xiàn)紅色方框,放到上面會出現(xiàn)提示信息。