Apache nifi的processor開發過程

Apache NiFi 是一個易於使用、功能強大而且可靠的資料處理和分發系統。Apache NiFi 是為資料流設計。它支援高度可配置的指示圖的資料路由、轉換和系統中介邏輯。nifi可以自己開發擴充套件外掛processor，下面介紹processor的開發過程。

方法/步驟1 建立工程

（01）環境準備，需要安裝jdk和maven。通過命令來檢查jdkhemaven是否已經安裝。

（02）開始建立processor工程。建立新的目錄，並在目錄下執行mvn archetype:generate。根據介面提示輸入相應的版本和工程資訊。命令執行完成後，就會生成nifi processor工程檔案。

方法/步驟2 編寫第一個processor

（01）工程生成後，在原始碼中可以找到一個預設的，可修改此檔案來編寫自己的第一個processor。

（02）為我的processor新增描述資訊，屬性，relation已經編寫初始化函式。如下圖所示：

（03）編寫onTrigger函式。也是最重要的函式。這個函式來實現主要的功能。此函式主要分為以下幾個內容：讀取FlowFile，獲取屬性設定，寫FlowFile提交到Relation。

方法/步驟3 編譯並部署

（01）編譯，在工程目錄下執行mvn install命令。執行成功後，會生成檔案。例如我的檔名稱為為：。這個檔案就是我們要部署的檔案

（02）把放到nifi安裝目錄下的lib目錄下。重新啟動nifi服務。

（03）在nifi的介面上就可以看到自己編寫的第一個processor了。