全コントローラー(アルファベット順)

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

  • コントローラーのタイプ(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 オブジェクトに解析します。