ApacheNiFi-プロセッサの分類

この章では、ApacheNiFiでのプロセスの分類について説明します。

データ取り込みプロセッサ

データ取り込みカテゴリのプロセッサは、NiFiデータフローにデータを取り込むために使用されます。これらは主に、apacheNiFiのデータフローの開始点です。これらのカテゴリに属するプロセッサには、GetFile、GetHTTP、GetFTP、GetKAFKAなどがあります。

ルーティングおよびメディエーションプロセッサ

ルーティングおよびメディエーションプロセッサは、フローファイルの属性またはコンテンツの情報に従って、フローファイルをさまざまなプロセッサまたはデータフローにルーティングするために使用されます。これらのプロセッサは、NiFiデータフローの制御も担当します。このカテゴリに属するプロセッサには、RouteOnAttribute、RouteOnContent、ControlRate、RouteTextなどがあります。

データベースアクセスプロセッサ

このデータベースアクセスカテゴリのプロセッサは、データを選択または挿入したり、データベースから他のSQLステートメントを実行および準備したりすることができます。これらのプロセッサは、主にApacheNiFiのデータ接続プールコントローラ設定を使用します。このカテゴリに属するプロセッサには、ExecuteSQL、PutSQL、PutDatabaseRecord、ListDatabaseTablesなどがあります。

属性抽出プロセッサ

属性抽出プロセッサは、NiFiデータフローでのフローファイル属性処理の抽出、分析、変更を担当します。このカテゴリに属するプロセッサには、UpdateAttribute、EvaluateJSONPath、ExtractText、AttributesToJSONなどがあります。

システム相互作用プロセッサ

システムインタラクションプロセッサは、任意のオペレーティングシステムでプロセスまたはコマンドを実行するために使用されます。これらのプロセッサは、さまざまなシステムと対話するために、多くの言語でスクリプトを実行します。このカテゴリに属するプロセッサには、ExecuteScript、ExecuteProcess、ExecuteGroovyScript、ExecuteStreamCommandなどがあります。

データ変換プロセッサ

データ変換に属するプロセッサは、フローファイルのコンテンツを変更できます。これらは、ユーザーがHTTPプロセッサを呼び出すためにHTTPボディとしてフローファイルを送信する必要がある場合に通常使用されるフローファイルのデータを完全に置き換えるために使用できます。このカテゴリに属するプロセッサには、ReplaceText、JoltTransformJSONなどがあります。

データプロセッサの送信

送信データプロセッサは、通常、データフローのエンドプロセッサです。これらのプロセッサは、データを保存するか、宛先サーバーに送信する責任があります。データの保存または送信に成功した後、これらのプロセッサは成功の関係でフローファイルをドロップします。このカテゴリに属するプロセッサには、PutEmail、PutKafka、PutSFTP、PutFile、PutFTPなどがあります。