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などがあります。

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

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

HTTPプロセッサ

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

AWSプロセッサ

AWSプロセッサは、アマゾンウェブサービスシステムとの相互作用に責任があります。このカテゴリに属する​​プロセッサには、GetSQS、PutSNS、PutS3Object、FetchS3Objectなどがあります。