全コントローラー(アルファベット順)¶
このトピックでは、アルファベット順の全オープンフローコントローラのリストを提供します。リストには次が含まれます。
コントローラーのタイプ(Snowflakeかどうか)
各コントローラーの名前
各コントローラーの概要
A¶
コントローラー |
説明 |
|
---|---|---|
ADLS プロセッサーの認証情報を定義します。 |
||
別の ADLSCredentialsService を動的に選択するために使用できる ADLSCredentialsService を提供します。 |
||
AWS Glue Schema Registry と相互作用するスキーマレジストリを提供し、Glue Schema Registry に保存されたスキーマを NiFi で使用できるようにします。 |
||
AWS MSK Kafka Brokers への接続をプロバイダーまたはコンシューマー操作用に提供し、管理します。 |
||
Snowflake |
AWS MSK Kafka Brokers への接続をプロバイダーまたはコンシューマー操作用に提供し、管理します。 |
|
Apicurioスキーマレジストリと相互作用するスキーマレジストリを提供し、Apicurioスキーマレジストリに格納されているスキーマを NiFi で使用できます。 |
||
Avro データを解析し、各 Avro 記録を個別の Record オブジェクトとして返します。 |
||
RecordSet の内容をバイナリー Avro 形式で書き込みます。 |
||
スキーマの登録とアクセスのためのサービスを提供します。 |
||
Amazon Web Services プロセッサーの認証情報を定義します。 |
||
Azure Blob ストレージファイルリソースを他のコンポーネントに提供します。 |
||
Cosmos DB (Core SQL API) への接続を構成し、他のCosmos DB 関連コンポーネントへのアクセスを提供するController Serviceを提供します。 |
||
Azure Data Lake Storage (ADLS) ファイルリソースを他のコンポーネントに提供します。 |
||
Azureイベントハブへの記録の形式と送信 |
||
Azure Storage クライアントライブラリ v12 を使用する Azure Storage プロセッサの認証情報を提供します。 |
||
別の AzureStorageCredentialsService_v12 を動的に選択するために使用できる AzureStorageCredentialsService_v12 をプロバイダーとして提供します。 |
C¶
コントローラー |
説明 |
|
---|---|---|
CEF (Common Event Format) イベントを解析し、各行を記録として返します。 |
||
バイトマーカーと4バイトで表される整数からなるヘッダーとして、Confluentエンコーディングに従ってスキーマ識別子を読み込みます。 |
||
バイトマーカーと4バイトで表される整数からなるヘッダーとして、Confluentエンコーディングに従ってスキーマ識別子を書き込みます。 |
||
Confluent スキーマレジストリと相互作用するスキーマレジストリを提供し、Confluent スキーマレジストリに保存されたスキーマを NiFi で使用できるようにします。 |
||
CSV 形式データを解析し、 CSV ファイルの各行を個別の記録として返します。 |
||
リロード可能な CSV ファイルベースの検索サービス。 |
||
RecordSet の内容を CSV データとして書き込みます。 |
D¶
コントローラー |
説明 |
|
---|---|---|
Snowflake |
ユーザー指定の SQL ステートメントを使用してデータベースを充実させることができる検索サービス。 |
|
リレーショナル データベースを基にした検索サービス。 |
||
構成されたデータベース接続を使用して記録を書き込むサービスを提供します。 |
||
データベース接続プーリングサービスを提供します。 |
||
別の DBCPService を動的に選択するために使用できる DBCPService を提供します。 |
||
Box API コールを使用できる Box クライアントオブジェクトを提供します。 |
||
キーに関連付けられた値を取得する分散マップ キャッシュ クライアントを選択できるようにします。 |
E¶
コントローラー |
説明 |
|
---|---|---|
Elasticsearch (low-level) REST クライアントを使用して Elasticsearch クライアントにアクセスするためのController Serviceです。 |
||
指定したドキュメントに関連する Elasticsearch Server の記録を ID から検索します。 |
||
指定したドキュメント ID に関連付けられた文字列値を Elasticsearch Server から検索します。 |
||
RecordSinkService をプロバイダーとして提供します。このプロバイダーは、指定されたライターを使用して電子メールで記録を送信し、形式を設定します。 |
||
埋め込まれたHazelcastを実行し、それにバックアップされたキャッシュインスタンスをプロバイダーするサービス。 |
||
Microsoft Excelドキュメントを解析し、各シートの各行を個別の記録として返します。 |
||
NiFi の外部で動作するHazelcastによってバックアップされたキャッシュインスタンスをプロバイダーするサービスです。 |
F¶
コントローラー |
説明 |
|
---|---|---|
RecordSet の内容を自由形式のテキストとして書き込みます。 |
G¶
コントローラー |
説明 |
|
---|---|---|
Google Cloud Platform プロセッサー用の認証情報を定義します。 |
||
Google Compute Storage (GCS) ファイルリソースを他のコンポーネントに提供します。 |
||
ログファイルなどの非構造化テキストデータを読み取り、処理できるようにデータを構造化するメカニズムを提供します。 |
H¶
コントローラー |
説明 |
|
---|---|---|
Hazelcastをバッキングキャッシュとして使う DistributedMapCacheClient の実装です。 |
||
HikariCP に基づいたデータベース接続プーリングサービスを提供します。 |
||
HTTP post を使って記録を形式化し、構成された uri に送信します。 |
I¶
コントローラー |
説明 |
|
---|---|---|
IP アドレスに対していくつかのタイプのエンリッチメント情報を提供するルックアップサービス。 |
J¶
コントローラー |
説明 |
|
---|---|---|
WebSocketClientService の実装。 |
||
WebSocketServerService の実装。 |
||
ベンダー固有のjavax.Protectオブジェクトを作成するための汎用サービスを提供します。 |
||
Java Naming and Directory Interface (JNDI) を使用して、既存の JMS ConnectionFactory を検索するサービスを提供します。 |
||
Box API コールを使用できる Box クライアントオブジェクトを提供します。 |
||
JSON の記録を解析し、各 JSON オブジェクトに対してユーザー定義の JSON パスを評価します。 |
||
RecordSet の結果を、 JSON Array または 1 行に 1 つの JSON オブジェクトとして書き込みます。 |
||
Snowflake |
JSON 構成に基づくテーブル列フィルターを提供します。 |
|
JSON を個々の Record オブジェクトに解析します。 |
||
OAuth 2の提供。 |
K¶
コントローラー |
説明 |
|
---|---|---|
Kafkaブローカーへの接続を提供・管理し、プロデューサまたはコンシューマ操作に使用します。 |
||
Snowflake |
Kafkaブローカーへの接続を提供・管理し、プロデューサまたはコンシューマ操作に使用します。 |
L¶
コントローラー |
説明 |
|
---|---|---|
RecordSinkService アプリケーションログへの記録 (nifi-app. |
M¶
コントローラー |
説明 |
|
---|---|---|
MapCacheServer とのコミュニケーション能力を提供します。 |
||
ソケット経由でアクセスできるマップ(キー/値)キャッシュをプロバイダー。 |
||
Snowflake |
クライアント証明書と client_credentials を使用して、Microsoft Graph API 用の OAuth2 アクセストークンを提供します。 |
|
Snowflake |
Microsoft 365 サービスとの対話に使用できる Microsoft Graph API の認証コードを提供します。 |
|
MongoDB への接続を構成し、その接続へのアクセスを他の Mongo- 関連コンポーネントに提供するController Serviceを提供します。 |
||
MongoDB を中心とした検索サービスを提供。 |
P¶
コントローラー |
説明 |
|
---|---|---|
Snowflake |
Apache Parquet 形式を用いた Apache Iceberg 用の記録シリアライズを提供します。 |
|
SSLContext PEM シークレットキーおよび証明書ファイルを使用して構成可能なプロバイダー。 |
||
Snowflake |
REST HTTP アクセスにおけるApache IcebergとApache Polarisカタログアクセスの統合を提供します。 |
|
リロード可能なプロパティファイルベースのルックアップサービス |
R¶
コントローラー |
説明 |
|
---|---|---|
別の RecordReaderFactory を動的に選択するために使用できる RecordReaderFactory を提供します。 |
||
別の RecordSetWriterFactory を動的に選択するために使用できる RecordSetWriterFactory を提供します。 |
||
別の RecordSinkService を動的に選択するために使用できる RecordSinkService を提供します。 |
||
Redisへの接続を提供するサービス。 |
||
DistributedMapCacheClient の実装で、Redis をバッキングキャッシュとして使用します。 |
||
REST サービスを使って値を調べます。 |
S¶
コントローラー |
説明 |
|
---|---|---|
Amazon Web Services (AWS) S3 ファイルリソースを他のコンポーネントに提供します。 |
||
Snowflake |
構成された OAuth2 アクセストークンプロバイダを使用して Salesforce から OAuth2 アクセストークンを取得し、トークンをデータクラウド API トークンと交換します。 |
|
ユーザーがスクリプト化された LookupService インスタンスを提供することで、受信フローファイルからの記録を充実させることができます。 |
||
ユーザーは、受信フローファイルから記録を読み取り/解析/生成するために、スクリプト化された RecordReaderFactory インスタンスを提供できます。 |
||
発信フローファイルに記録を書き込むために、ユーザーがスクリプト化された RecordSetWriterFactory インスタンスを提供できるようにします。 |
||
ユーザーがスクリプト化された RecordSinkService インスタンスを提供し、希望のターゲットに記録を送信できるようにします。 |
||
SetCacheServer とのコミュニケーション能力を提供します。 |
||
ソケット経由でアクセスできるセット (一意な値の集まり) キャッシュを提供します。 |
||
リロード可能な CSV ファイルベースの検索サービス。 |
||
リレーショナル データベースを基にした検索サービス。 |
||
ユーザーがキー/値のペアをユーザー定義プロパティとして追加できるようにします。 |
||
DistributedMapCacheClient の実装で、Redis をバッキングキャッシュとして使用します。 |
||
ユーザーがスクリプト化された LookupService インスタンスを提供することで、受信フローファイルからの記録を充実させることができます。 |
||
Slack Post Message API を使って形式を整え、構成されたチャンネルに記録を送信します。 |
||
共有認証コードによる SMB セッションへのアクセスを提供します。 |
||
Snowflake |
Snowflakeサービスへのプールされたデータベース接続の提供 |
|
Snowflake |
Snowflakeをサポートするデータベース方言サービス。 |
|
Snowflake |
||
Snowflake |
||
Snowflake |
API AnthropicのClaude AI モデルとの統合を提供するController Serviceです。 |
|
Azure クライアントで使用する認証情報を提供します。 |
||
Snowflake |
Databricksクライアント。 |
|
Dropbox プロセッサーの認証情報を定義します。 |
||
他のコンポーネントにファイルリソースを提供します。 |
||
HashiCorp Vault と対話するためのController Service。 |
||
複数の Processor が同じ HTTP リクエストとやり取りできるように、Processor の外部で HTTP リクエストとレスポンスを保存したり取得したりする機能を提供します。 |
||
Snowflake |
HubSpot HTTP api と統合する HubSpot Controller Service。 |
|
JSON スキーマの登録とアクセスのためのサービスを提供します。 |
||
Azure ADX クラスターにフローファイルコンテンツのバッチまたはストリームフローファイルコンテンツを送信します。 |
||
Azure Data Explorer向けKustoクエリサービスの標準実装 |
||
Snowflake |
Milvusインスタンスへの接続サービスを提供します。 |
|
OAuth 2の提供。 |
||
Snowflake |
Openflow OCR サービスへの統合を提供します。 |
|
Snowflake |
OpenAI のチャット完了 API との統合を提供するController Serviceです。 |
|
PGP シークレットキーサービスは、ファイルやプロパティから読み込んだシークレットキーをプロバイダーとして提供します。 |
||
PGP ファイルから読み込んだ公開キーを提供する公開キーサービス |
||
シークレットキーサービスは、構成されたソースからロードされたシークレットキーへのアクセスを提供します。 |
||
プロキシサーバーを使用するための、さまざまな NiFi コンポーネントの構成セットを提供します。 |
||
SSLContextService の制限付き実装。 |
||
S3 PutおよびS3 Fetch操作に構成可能な暗号化を追加します。 |
||
Snowflake |
Salesforce APIs への接続サービスを提供します。 |
|
Snowflake |
Salesforce Data Cloud APIs への接続サービスを提供します。 |
|
SSLContextService の標準実装。 |
||
Snowflake |
テーブルの状態を提供し管理するController Service。 |
|
Snowflake |
Vectara Controller ServiceはVectara HTTP Apiと統合します。 |
|
標準的な HTTP 接続プロパティの構成をサポートするウェブクライアントサービスプロバイダー。 |
||
Snowflake |
テーブルスキーマのハッシュを格納するために、組み込みの NiFi 状態管理を使用します。 |
|
ログファイルなどの RFC 5424 準拠の Syslog データを読み取り、処理できるようにデータを構造化するメカニズムを提供します。 |
||
RFC5424 と RFC3164 に従って、Syslogメッセージの内容の解析を試みます。 |
U¶
コントローラー |
説明 |
|
---|---|---|
記録を UDP データグラムパケットとして形式化し、構成可能な宛先に送信します。 |
V¶
コントローラー |
説明 |
|
---|---|---|
Least-Recently-Used アルゴリズムに基づいて要素を削除するスキーマ・キャッシュをプロバイダーとして提供します。 |
W¶
コントローラー |
説明 |
|
---|---|---|
ConsumeWindowsEventLog, ParseEvtx, などによって生成された XML コンテンツとして Windows イベントログデータを読み込みます。 |
X¶
コントローラー |
説明 |
|
---|---|---|
リロード可能な XML ファイルベースの検索サービス。 |
||
XML コンテンツを読み取り、Record オブジェクトを作成します。 |
||
XML に RecordSet を書き込みます。 |
Y¶
コントローラー |
説明 |
|
---|---|---|
YAML を個々の Record オブジェクトに解析します。 |