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了。