Apache NiFi - 自定義處理器



Apache NiFi 是一個開源平臺,允許開發者向 NiFi 庫新增自定義處理器。請按照以下步驟建立自定義處理器。

> mvn archetype:generate
  • 在原型專案中搜索 nifi 型別。

  • 選擇 org.apache.nifi:nifi-processor-bundle-archetype 專案。

  • 然後從版本列表中選擇最新版本,本教程使用 1.7.1。

  • 輸入 groupId、artifactId、version、package 和 artifactBaseName 等。

  • 然後將建立一個包含兩個目錄的 Maven 專案。

    • nifi-<artifactBaseName>-processors

    • nifi-<artifactBaseName>-nar

  • 在 nifi-<artifactBaseName>-processors 目錄中執行以下命令,將專案新增到 Eclipse 中。

mvn install eclipse:eclipse
  • 開啟 Eclipse 並從檔案選單中選擇匯入。

  • 然後選擇“將現有專案匯入工作區”,並將專案從 nifi-<artifactBaseName>-processors 目錄新增到 Eclipse 中。

  • 在 public void onTrigger(ProcessContext context, ProcessSession session) 函式中新增您的程式碼,該函式在每次排程處理器執行時都會執行。

  • 然後透過執行以下命令將程式碼打包到 NAR 檔案中。

mvn clean install
  • NAR 檔案將建立在 nifi--nar/target 目錄中。

  • 將 NAR 檔案複製到 Apache NiFi 的 lib 資料夾並重啟 NiFi。

  • NiFi 成功重啟後,檢查處理器列表中是否有新的自定義處理器。

  • 如有任何錯誤,請檢查 ./logs/nifi.log 檔案。

廣告
© . All rights reserved.