1. 通過Ambari QuickLink打開Nifi UI
2. 創(chuàng)建ProcessorGroup
a. 拖動頁面上方工具條中的ProcessorGroup圖標至繪圖區(qū)
b. 命名Group并雙擊打開
3.創(chuàng)建Overall flow
1)添加GetFile Processor
a.拖動頁面上方工具條中的Processor圖標至繪圖區(qū)可以開始創(chuàng)建數(shù)據(jù)流荷辕,成功后如圖
b.在搜索框處輸入想要添加的Processor芹敌。此處輸入GetFile颖侄,然后點擊Add绸狐,GetFile Processor 添加成功。
c.雙擊GetFile處理器或者右擊選擇Configure進行配置,根據(jù)自身環(huán)境和需求灾锯,填寫相關(guān)配置。然后點擊APPLY嗅榕。
2)添加PutHive Processor
a.同理添加PutHive顺饮,并做相應(yīng)的配置。與GutFile不同的是凌那,此處要創(chuàng)建Reader/Writer兼雄。
b)Reader/Writer等相關(guān)配置如下
insurance_schema
c)如圖,點擊右邊的設(shè)置按鈕可以進入配置帽蝶,點擊閃電樣式的按鈕可以啟動赦肋。
d)至此,PutHive Processor創(chuàng)建添加成功。
3)連接兩個Processor
a.每個處理器都有一組定義的“關(guān)系”佃乘,最基本的是success和failure囱井。把鼠標停在GetFile Processor,會看到一個箭頭趣避,拖動箭頭到PutHive 庞呕,顯示success即可。
b.此時程帕,PutHive上仍顯示警告住练,提示為success、retry和failure關(guān)系未連接到其他組件和自動終止愁拭∨煨撸可以右擊configure,在setting中勾選中success敛苇、retry和failure即可實現(xiàn)自動終止。
4.啟動Processor
a.依次啟動Processor顺呕,一般按從后往前的順序右擊選擇start枫攀。
b.運行成功后,可以看到數(shù)據(jù)再不同位置的轉(zhuǎn)移以及數(shù)據(jù)流的大小株茶、時間等来涨。NiFi為back?pressure提供了兩個配置元件。分別對應(yīng)的是對象數(shù)量和數(shù)據(jù)大小启盛。并且進度條基于隊列百分比改變顏色:綠色(0-60%)蹦掐,黃色(61-85%)和紅色(86-100%)。鼠標懸停在上面可以顯示精確的百分比僵闯。
c.當運行出現(xiàn)問題時卧抗,右上角會出現(xiàn)紅色方框,放到上面會出現(xiàn)提示信息鳖粟。