全コントローラー（アルファベット順）¶

このトピックでは、アルファベット順の全オープンフローコントローラのリストを提供します。リストには次が含まれます。

コントローラーのタイプ（Snowflakeかどうか）

各コントローラーの名前

各コントローラーの概要

A¶

	コントローラー	説明
	ADLSCredentialsControllerService	ADLS プロセッサーの認証情報を定義します。
	ADLSCredentialsControllerServiceLookup	別の ADLSCredentialsService を動的に選択するために使用できる ADLSCredentialsService を提供します。
	AmazonGlueSchemaRegistry	AWS Glue Schema Registry と相互作用するスキーマレジストリを提供し、Glue Schema Registry に保存されたスキーマを NiFi で使用できるようにします。
	AmazonMSKConnectionService	AWS MSK Kafka Brokers への接続をプロバイダーまたはコンシューマー操作用に提供し、管理します。
Snowflake	AmazonMSKConnectionService	AWS MSK Kafka Brokers への接続をプロバイダーまたはコンシューマー操作用に提供し、管理します。
	ApicurioSchemaRegistry	Apicurioスキーマレジストリと相互作用するスキーマレジストリを提供し、Apicurioスキーマレジストリに格納されているスキーマを NiFi で使用できます。
	AvroReader	Avro データを解析し、各 Avro 記録を個別の Record オブジェクトとして返します。
	AvroRecordSetWriter	RecordSet の内容をバイナリー Avro 形式で書き込みます。
	AvroSchemaRegistry	スキーマの登録とアクセスのためのサービスを提供します。
	AWSCredentialsProviderControllerService	Amazon Web Services プロセッサーの認証情報を定義します。
	AzureBlobStorageFileResourceService	Azure Blob ストレージファイルリソースを他のコンポーネントに提供します。
	AzureCosmosDBClientService	Cosmos DB (Core SQL API) への接続を構成し、他のCosmos DB 関連コンポーネントへのアクセスを提供するController Serviceを提供します。
	AzureDataLakeStorageFileResourceService	Azure Data Lake Storage (ADLS) ファイルリソースを他のコンポーネントに提供します。
	AzureEventHubRecordSink	Azureイベントハブへの記録の形式と送信
	AzureStorageCredentialsControllerService_v12	Azure Storage クライアントライブラリ v12 を使用する Azure Storage プロセッサの認証情報を提供します。
	AzureStorageCredentialsControllerServiceLookup_v12	別の AzureStorageCredentialsService_v12 を動的に選択するために使用できる AzureStorageCredentialsService_v12 をプロバイダーとして提供します。

C¶

	コントローラー	説明
	CEFReader	CEF (Common Event Format) イベントを解析し、各行を記録として返します。
	ConfluentEncodedSchemaReferenceReader	バイトマーカーと4バイトで表される整数からなるヘッダーとして、Confluentエンコーディングに従ってスキーマ識別子を読み込みます。
	ConfluentEncodedSchemaReferenceWriter	バイトマーカーと4バイトで表される整数からなるヘッダーとして、Confluentエンコーディングに従ってスキーマ識別子を書き込みます。
	ConfluentSchemaRegistry	Confluent スキーマレジストリと相互作用するスキーマレジストリを提供し、Confluent スキーマレジストリに保存されたスキーマを NiFi で使用できるようにします。
	CSVReader	CSV 形式データを解析し、 CSV ファイルの各行を個別の記録として返します。
	CSVRecordLookupService	リロード可能な CSV ファイルベースの検索サービス。
	CSVRecordSetWriter	RecordSet の内容を CSV データとして書き込みます。

D¶

	コントローラー	説明
Snowflake	DatabaseLookup	ユーザー指定の SQL ステートメントを使用してデータベースを充実させることができる検索サービス。
	DatabaseRecordLookupService	リレーショナルデータベースを基にした検索サービス。
	DatabaseRecordSink	構成されたデータベース接続を使用して記録を書き込むサービスを提供します。
	DBCPConnectionPool	データベース接続プーリングサービスを提供します。
	DBCPConnectionPoolLookup	別の DBCPService を動的に選択するために使用できる DBCPService を提供します。
	DeveloperBoxClientService	Box API コールを使用できる Box クライアントオブジェクトを提供します。
	DistributedMapCacheLookupService	キーに関連付けられた値を取得する分散マップキャッシュクライアントを選択できるようにします。

E¶

	コントローラー	説明
	ElasticSearchClientServiceImpl	Elasticsearch (low-level) REST クライアントを使用して Elasticsearch クライアントにアクセスするためのController Serviceです。
	ElasticSearchLookupService	指定したドキュメントに関連する Elasticsearch Server の記録を ID から検索します。
	ElasticSearchStringLookupService	指定したドキュメント ID に関連付けられた文字列値を Elasticsearch Server から検索します。
	EmailRecordSink	RecordSinkService をプロバイダーとして提供します。このプロバイダーは、指定されたライターを使用して電子メールで記録を送信し、形式を設定します。
	EmbeddedHazelcastCacheManager	埋め込まれたHazelcastを実行し、それにバックアップされたキャッシュインスタンスをプロバイダーするサービス。
	ExcelReader	Microsoft Excelドキュメントを解析し、各シートの各行を個別の記録として返します。
	ExternalHazelcastCacheManager	NiFi の外部で動作するHazelcastによってバックアップされたキャッシュインスタンスをプロバイダーするサービスです。

F¶

	コントローラー	説明
	FreeFormTextRecordSetWriter	RecordSet の内容を自由形式のテキストとして書き込みます。

G¶

	コントローラー	説明
	GCPCredentialsControllerService	Google Cloud Platform プロセッサー用の認証情報を定義します。
	GCSFileResourceService	Google Compute Storage (GCS) ファイルリソースを他のコンポーネントに提供します。
	GrokReader	ログファイルなどの非構造化テキストデータを読み取り、処理できるようにデータを構造化するメカニズムを提供します。

H¶

	コントローラー	説明
	HazelcastMapCacheClient	Hazelcastをバッキングキャッシュとして使う DistributedMapCacheClient の実装です。
	HikariCPConnectionPool	HikariCP に基づいたデータベース接続プーリングサービスを提供します。
	HttpRecordSink	HTTP post を使って記録を形式化し、構成された uri に送信します。

I¶

	コントローラー	説明
	IPLookupService	IP アドレスに対していくつかのタイプのエンリッチメント情報を提供するルックアップサービス。

J¶

	コントローラー	説明
	JettyWebSocketClient	WebSocketClientService の実装。
	JettyWebSocketServer	WebSocketServerService の実装。
	JMSConnectionFactoryProvider	ベンダー固有のjavax.Protectオブジェクトを作成するための汎用サービスを提供します。
	JndiJmsConnectionFactoryProvider	Java Naming and Directory Interface (JNDI) を使用して、既存の JMS ConnectionFactory を検索するサービスを提供します。
	JsonConfigBasedBoxClientService	Box API コールを使用できる Box クライアントオブジェクトを提供します。
	JsonPathReader	JSON の記録を解析し、各 JSON オブジェクトに対してユーザー定義の JSON パスを評価します。
	JsonRecordSetWriter	RecordSet の結果を、 JSON Array または 1 行に 1 つの JSON オブジェクトとして書き込みます。
Snowflake	JsonTableColumnFilter	JSON 構成に基づくテーブル列フィルターを提供します。
	JsonTreeReader	JSON を個々の Record オブジェクトに解析します。
	JWTBearerOAuth2AccessTokenProvider	OAuth 2の提供。

K¶

	コントローラー	説明
	Kafka3ConnectionService	Kafkaブローカーへの接続を提供・管理し、プロデューサまたはコンシューマ操作に使用します。
Snowflake	Kafka3ConnectionService	Kafkaブローカーへの接続を提供・管理し、プロデューサまたはコンシューマ操作に使用します。

L¶

	コントローラー	説明
	LoggingRecordSink	RecordSinkService アプリケーションログへの記録 (nifi-app.

M¶

	コントローラー	説明
	MapCacheClientService	MapCacheServer とのコミュニケーション能力を提供します。
	MapCacheServer	ソケット経由でアクセスできるマップ(キー/値)キャッシュをプロバイダー。
Snowflake	MicrosoftClientCertificateOAuth2TokenProvider	クライアント証明書と client_credentials を使用して、Microsoft Graph API 用の OAuth2 アクセストークンを提供します。
Snowflake	MicrosoftGraphAuthenticationProvider	Microsoft 365 サービスとの対話に使用できる Microsoft Graph API の認証コードを提供します。
	MongoDBControllerService	MongoDB への接続を構成し、その接続へのアクセスを他の Mongo- 関連コンポーネントに提供するController Serviceを提供します。
	MongoDBLookupService	MongoDB を中心とした検索サービスを提供。

P¶

	コントローラー	説明
Snowflake	ParquetIcebergWriter	Apache Parquet 形式を用いた Apache Iceberg 用の記録シリアライズを提供します。
	PEMEncodedSSLContextProvider	SSLContext PEM シークレットキーおよび証明書ファイルを使用して構成可能なプロバイダー。
Snowflake	PolarisIcebergCatalog	REST HTTP アクセスにおけるApache IcebergとApache Polarisカタログアクセスの統合を提供します。
	PropertiesFileLookupService	リロード可能なプロパティファイルベースのルックアップサービス

R¶

	コントローラー	説明
	ReaderLookup	別の RecordReaderFactory を動的に選択するために使用できる RecordReaderFactory を提供します。
	RecordSetWriterLookup	別の RecordSetWriterFactory を動的に選択するために使用できる RecordSetWriterFactory を提供します。
	RecordSinkServiceLookup	別の RecordSinkService を動的に選択するために使用できる RecordSinkService を提供します。
	RedisConnectionPoolService	Redisへの接続を提供するサービス。
	RedisDistributedMapCacheClientService	DistributedMapCacheClient の実装で、Redis をバッキングキャッシュとして使用します。
	RestLookupService	REST サービスを使って値を調べます。

S¶

	コントローラー	説明
	S3FileResourceService	Amazon Web Services (AWS) S3 ファイルリソースを他のコンポーネントに提供します。
Snowflake	SalesforceDataCloudOAuthTokenProvider	構成された OAuth2 アクセストークンプロバイダを使用して Salesforce から OAuth2 アクセストークンを取得し、トークンをデータクラウド API トークンと交換します。
	ScriptedLookupService	ユーザーがスクリプト化された LookupService インスタンスを提供することで、受信フローファイルからの記録を充実させることができます。
	ScriptedReader	ユーザーは、受信フローファイルから記録を読み取り/解析/生成するために、スクリプト化された RecordReaderFactory インスタンスを提供できます。
	ScriptedRecordSetWriter	発信フローファイルに記録を書き込むために、ユーザーがスクリプト化された RecordSetWriterFactory インスタンスを提供できるようにします。
	ScriptedRecordSink	ユーザーがスクリプト化された RecordSinkService インスタンスを提供し、希望のターゲットに記録を送信できるようにします。
	SetCacheClientService	SetCacheServer とのコミュニケーション能力を提供します。
	SetCacheServer	ソケット経由でアクセスできるセット (一意な値の集まり) キャッシュを提供します。
	SimpleCsvFileLookupService	リロード可能な CSV ファイルベースの検索サービス。
	SimpleDatabaseLookupService	リレーショナルデータベースを基にした検索サービス。
	SimpleKeyValueLookupService	ユーザーがキー/値のペアをユーザー定義プロパティとして追加できるようにします。
	SimpleRedisDistributedMapCacheClientService	DistributedMapCacheClient の実装で、Redis をバッキングキャッシュとして使用します。
	SimpleScriptedLookupService	ユーザーがスクリプト化された LookupService インスタンスを提供することで、受信フローファイルからの記録を充実させることができます。
	SlackRecordSink	Slack Post Message API を使って形式を整え、構成されたチャンネルに記録を送信します。
	SmbjClientProviderService	共有認証コードによる SMB セッションへのアクセスを提供します。
Snowflake	SnowflakeConnectionService	Snowflakeサービスへのプールされたデータベース接続の提供
Snowflake	SnowflakeDatabaseDialectService	Snowflakeをサポートするデータベース方言サービス。
Snowflake	SnowflakeSignJWTService
Snowflake	SnowflakeTableSchemaRegistry
Snowflake	StandardAnthropicLLMService	API AnthropicのClaude AI モデルとの統合を提供するController Serviceです。
	StandardAzureCredentialsControllerService	Azure クライアントで使用する認証情報を提供します。
Snowflake	StandardDatabricksWorkspaceClientService	Databricksクライアント。
	StandardDropboxCredentialService	Dropbox プロセッサーの認証情報を定義します。
	StandardFileResourceService	他のコンポーネントにファイルリソースを提供します。
	StandardHashiCorpVaultClientService	HashiCorp Vault と対話するためのController Service。
	StandardHttpContextMap	複数の Processor が同じ HTTP リクエストとやり取りできるように、Processor の外部で HTTP リクエストとレスポンスを保存したり取得したりする機能を提供します。
Snowflake	StandardHubSpotClientService	HubSpot HTTP api と統合する HubSpot Controller Service。
	StandardJsonSchemaRegistry	JSON スキーマの登録とアクセスのためのサービスを提供します。
	StandardKustoIngestService	Azure ADX クラスターにフローファイルコンテンツのバッチまたはストリームフローファイルコンテンツを送信します。
	StandardKustoQueryService	Azure Data Explorer向けKustoクエリサービスの標準実装
Snowflake	StandardMilvusConnectionService	Milvusインスタンスへの接続サービスを提供します。
	StandardOauth2AccessTokenProvider	OAuth 2の提供。
Snowflake	StandardOCRService	Openflow OCR サービスへの統合を提供します。
Snowflake	StandardOpenAILLMService	OpenAI のチャット完了 API との統合を提供するController Serviceです。
	StandardPGPPrivateKeyService	PGP シークレットキーサービスは、ファイルやプロパティから読み込んだシークレットキーをプロバイダーとして提供します。
	StandardPGPPublicKeyService	PGP ファイルから読み込んだ公開キーを提供する公開キーサービス
	StandardPrivateKeyService	シークレットキーサービスは、構成されたソースからロードされたシークレットキーへのアクセスを提供します。
	StandardProxyConfigurationService	プロキシサーバーを使用するための、さまざまな NiFi コンポーネントの構成セットを提供します。
	StandardRestrictedSSLContextService	SSLContextService の制限付き実装。
	StandardS3EncryptionService	S3 PutおよびS3 Fetch操作に構成可能な暗号化を追加します。
Snowflake	StandardSalesforceClientService	Salesforce APIs への接続サービスを提供します。
Snowflake	StandardSalesforceDataCloudClientService	Salesforce Data Cloud APIs への接続サービスを提供します。
	StandardSSLContextService	SSLContextService の標準実装。
Snowflake	StandardTableStateService	テーブルの状態を提供し管理するController Service。
Snowflake	StandardVectaraClientService	Vectara Controller ServiceはVectara HTTP Apiと統合します。
	StandardWebClientServiceProvider	標準的な HTTP 接続プロパティの構成をサポートするウェブクライアントサービスプロバイダー。
Snowflake	StateManagedCdcSchemaRegistry	テーブルスキーマのハッシュを格納するために、組み込みの NiFi 状態管理を使用します。
	Syslog5424Reader	ログファイルなどの RFC 5424 準拠の Syslog データを読み取り、処理できるようにデータを構造化するメカニズムを提供します。
	SyslogReader	RFC5424 と RFC3164 に従って、Syslogメッセージの内容の解析を試みます。

U¶

	コントローラー	説明
	UDPEventRecordSink	記録を UDP データグラムパケットとして形式化し、構成可能な宛先に送信します。

V¶

	コントローラー	説明
	VolatileSchemaCache	Least-Recently-Used アルゴリズムに基づいて要素を削除するスキーマ・キャッシュをプロバイダーとして提供します。

W¶

	コントローラー	説明
	WindowsEventLogReader	ConsumeWindowsEventLog, ParseEvtx, などによって生成された XML コンテンツとして Windows イベントログデータを読み込みます。

X¶

	コントローラー	説明
	XMLFileLookupService	リロード可能な XML ファイルベースの検索サービス。
	XMLReader	XML コンテンツを読み取り、Record オブジェクトを作成します。
	XMLRecordSetWriter	XML に RecordSet を書き込みます。

Y¶

	コントローラー	説明
	YamlTreeReader	YAML を個々の Record オブジェクトに解析します。