Apache NiFi-プロセッサの分類

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

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

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

ルーティングおよび調停プロセッサ

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

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

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

属性抽出プロセッサ

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

システムインタラクションプロセッサ

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

データ変換プロセッサ

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

データプロセッサの送信

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

分割および集約プロセッサ

これらのプロセッサは、フローファイルに存在するコンテンツを分割およびマージするために使用されます。このカテゴリに属するプロセッサには、SplitText、SplitJson、SplitXml、MergeContent、SplitContentなどがあります。

HTTPプロセッサー

これらのプロセッサーは、HTTPおよびHTTPS呼び出しを処理します。このカテゴリに属するプロセッサには、InvokeHTTP、PostHTTP、ListenHTTPなどがあります。

AWSプロセッサー

AWSプロセッサは、Amazon Webサービスシステムとのやり取りを担当します。このカテゴリに属するプロセッサには、GetSQS、PutSNS、PutS3Object、FetchS3Objectなどがあります。

Apache-nifi-processors-categorization

目次