Apache NiFi - 建立資料流

Apache NiFi 提供了大量元件，幫助開發人員為任何型別的協議或資料來源建立資料流。要建立資料流，開發人員可以從選單欄將元件拖動到畫布上，然後透過單擊並拖動滑鼠從一個元件連線到另一個元件。

通常，NiFi 在資料流的起始位置有一個監聽器元件，例如 getfile，它從源系統獲取資料。在另一端，有一個傳送器元件，例如 putfile，並且中間有一些元件來處理資料。

例如，讓我們建立一個數據流，它從一個目錄中獲取一個空檔案，在該檔案中新增一些文字，然後將其放入另一個目錄中。

• 首先，將處理器圖示拖到 NiFi 畫布上，並從列表中選擇 GetFile 處理器。

• 建立一個輸入目錄，例如 **c:\inputdir**。

• 右鍵單擊處理器並選擇配置，在屬性選項卡中新增 **輸入目錄 (c:\inputdir)**，然後單擊應用並返回畫布。

• 將處理器圖示拖到畫布上，並從列表中選擇 ReplaceText 處理器。

• 右鍵單擊處理器並選擇配置。在**屬性**選項卡中，在替換值的文字框中新增一些文字，例如 **“Hello tutorialspoint.com”**，然後單擊應用。

• 轉到設定選項卡，選中右側的失敗複選框，然後返回畫布。

• 將 GetFIle 處理器連線到 ReplaceText 的成功關係。

• 將處理器圖示拖到畫布上，並從列表中選擇 PutFile 處理器。

• 建立一個輸出目錄，例如 **c:\outputdir**。

• 右鍵單擊處理器並選擇配置。在屬性選項卡中，新增 **目錄 (c:\outputdir)**，然後單擊應用並返回畫布。

• 轉到設定選項卡，選中右側的失敗和成功複選框，然後返回畫布。

• 將 ReplaceText 處理器連線到 PutFile 的成功關係。

• 現在啟動資料流，並在輸入目錄中新增一個空檔案，您將看到它會移動到輸出目錄，並且文字將新增到檔案中。

透過遵循上述步驟，開發人員可以選擇任何處理器和其他 NiFi 元件來為其組織或客戶建立合適的資料流。