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了。
-
微信openid獲取教程
用微信支付平臺發放紅包必須上傳使用者的微信openid,想要匯出微信openid可以按以下步驟來做。操作方法(01)進入微信openid匯出平臺,根據下圖1更新列表;2重新整理粉絲資訊;3匯出資料;(02)獲得的微信平臺openid資料如下(03)把openid拷貝到t型臺文件裡,格式如下。(04)匯入到微信商戶平...
-
解決TeamViewer無法按給定網路地址聯絡夥伴
在使用TeamViewer遠端控制電腦的時候,突然出現下圖提示無法建立連線,無法按給定網路地址聯絡夥伴。然後不管怎麼試,都彈出這個連線地址。下面是本人親身經歷和排除方法,僅供參考。操作方法(01)首先第一步就是修復一下網路連線,開啟網路和共享中心。(02)選擇自己使用的上...
-
金萬維動態域名教程
現如今有很多nat123、金萬維等類似的建站軟體,那麼怎麼用金萬維獲得屬於自己的動態域名呢?操作方法(01)登陸金萬維伺服器端,進入配置介面,點選配件許可證,然後點選“點選申請試用賬號”。(02)按提示輸入相關資訊,完成註冊。註冊完成後,一般建議勾選“啟動動態域名解析”,這...
-
如何把檔案轉換成PDF格式?
PDF格式在如今使用頻率越來越高,在一些文件中,PDF往往比較方便文字及圖片的檢視。那麼如何把檔案直接轉換成PDF格式呢?以福昕高階PDF編輯器為例,把文件改成方便的PDF格式進行瀏覽和編輯。操作方法(01)PDF格式的文件很多,一些方便的功能可以直接在PDF編輯器中實現。怎...