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