Apache NiFi - 處理器關係



在 Apache NiFi 資料流中,FlowFile 透過連線從一個處理器移動到另一個處理器,連線的有效性透過處理器之間的關係進行驗證。每當建立連線時,開發人員都會選擇這些處理器之間的一種或多種關係。

Configure Processor

如上圖所示,黑色矩形中的複選框是關係。如果開發人員選中這些複選框,則當關系成功或失敗或兩者兼有時,FlowFile 將終止於該特定處理器。

成功

當處理器成功處理 FlowFile(例如從任何資料來源儲存或獲取資料,而不會遇到任何連線、身份驗證或任何其他錯誤)時,FlowFile 將進入成功關係。

失敗

當處理器無法無錯誤地處理 FlowFile(例如身份驗證錯誤或連線問題等)時,FlowFile 將進入失敗關係。

開發人員還可以使用連線將 FlowFile 傳輸到其他處理器。開發人員可以選擇並進行負載均衡,但負載均衡只是在 1.8 版本中釋出的,本教程中不會介紹。

Failure

如上圖所示,紅色標記的連線具有失敗關係,這意味著所有帶有錯誤的 FlowFile 將進入左側的處理器,相應地,所有沒有錯誤的 FlowFile 將傳輸到綠色標記的連線。

現在讓我們繼續討論其他關係。

comms.failure

當由於通訊故障無法從遠端伺服器獲取 FlowFile 時,將滿足此關係。

not.found

對於我們從遠端伺服器收到“未找到”訊息的任何 FlowFile,都將移動到**not.found**關係。

permission.denied

當 NiFi 由於許可權不足而無法從遠端伺服器獲取 FlowFile 時,它將透過此關係移動。

廣告
© . All rights reserved.