所有控制器（按字母顺序排列）¶

本主题按字母顺序提供所有 OpenFlow 控制器的列表。该列表包括：

控制器类型（是否为 Snowflake）

每个控制器的名称

每个控制器的摘要

A¶

	控制器	描述
	ADLSCredentialsControllerService	定义 ADLS 处理器的凭据。
	ADLSCredentialsControllerServiceLookup	提供可用于动态选择另一个 ADLSCredentialsService 的 ADLSCredentialsService。
	AmazonGlueSchemaRegistry	提供与 AWS Glue 架构注册表交互的架构注册表，以便存储在 Glue 架构注册表中的架构可以在 NiFi 中使用。
	AmazonMSKConnectionService	为生产者或使用者运营提供和管理与 AWS MSK Kafka 代理的连接。
Snowflake	AmazonMSKConnectionService	为生产者或使用者运营提供和管理与 AWS MSK Kafka 代理的连接。
	ApicurioSchemaRegistry	提供与 Apicurio 架构注册表交互的架构注册表，以便存储在 Apicurio 架构注册表中的架构可以在 NiFi 中使用。
	AvroReader	解析 Avro 数据并将每条 Avro 记录作为单独的 Record 对象返回。
	AvroRecordSetWriter	以二进制 Avro 格式写入 RecordSet 的内容。
	AvroSchemaRegistry	提供用于注册和访问架构的服务。
	AWSCredentialsProviderControllerService	定义 Amazon Web Services 处理器的凭据。
	AzureBlobStorageFileResourceService	为其他组件提供 Azure Blob 存储文件资源。
	AzureCosmosDBClientService	提供控制器服务，用于配置与 Cosmos DB (Core SQL API) 的连接，并向其他 Cosmos DB 相关组件提供对该连接的访问权限。
	AzureDataLakeStorageFileResourceService	为其他组件提供 Azure Data Lake Storage (ADLS) 文件资源。
	AzureEventHubRecordSink	格式化记录并将其发送到 Azure 事件中心
	AzureStorageCredentialsControllerService_v12	使用 Azure 存储客户端库 v12 为 Azure 存储处理器提供凭据。
	AzureStorageCredentialsControllerServiceLookup_v12	提供一个 AzureStorageCredentialsService_v12，可用于动态选择另一个 AzureStorageCredentialsService_v12。

C¶

	控制器	描述
	CEFReader	解析 CEF（通用事件格式）事件，将每行作为记录返回。
	ConfluentEncodedSchemaReferenceReader	根据 Confluent 编码将架构标识符读取为标头，该标头由字节标记和表示为四字节的整数组成
	ConfluentEncodedSchemaReferenceWriter	根据 Confluent 编码将架构标识符写为标头，该标头由字节标记和表示为四字节的整数组成
	ConfluentSchemaRegistry	提供与 Confluent 架构注册表交互的架构注册表，以便存储在 Confluent 架构注册表中的架构可以在 NiFi 中使用。
	CSVReader	解析 CSV 格式的数据，将 CSV 文件中的每一行作为单独的记录返回。
	CSVRecordLookupService	一种可重载、基于 CSV 文件的查找服务。
	CSVRecordSetWriter	以 CSV 数据的形式写入 RecordSet 的内容。

D¶

	控制器	描述
Snowflake	DatabaseLookup	一种查找服务，允许使用用户指定的 SQL 语句丰富数据库信息。
	DatabaseRecordLookupService	一种基于关系数据库的查找服务。
	DatabaseRecordSink	提供使用配置的数据库连接写入记录的服务。
	DBCPConnectionPool	提供数据库连接池服务。
	DBCPConnectionPoolLookup	提供可用于动态选择另一个 DBCPService 的 DBCPService。
	DeveloperBoxClientService	提供 Box 客户端对象，通过这些对象可以使用 Box API 调用。
	DistributedMapCacheLookupService	允许选择分布式映射缓存客户端来检索与键相关的值。

E¶

	控制器	描述
	ElasticSearchClientServiceImpl	一款用于访问 Elasticsearch 客户端的控制器服务，使用的是 Elasticsearch（低级）REST 客户端。
	ElasticSearchLookupService	从 Elasticsearch 服务器中查找与指定文档 ID 关联的记录。
	ElasticSearchStringLookupService	从 Elasticsearch 服务器中查找与指定文档 ID 关联的字符串值。
	EmailRecordSink	提供了一个 RecordSinkService，可用于通过电子邮件发送记录，格式由指定写入器确定。
	EmbeddedHazelcastCacheManager	运行嵌入式 Hazelcast 并提供由其支持的缓存实例的服务。
	ExcelReader	解析 Microsoft Excel 文档，将每张表中的每一行作为单独的记录返回。
	ExternalHazelcastCacheManager	提供由运行在 NiFi 之外的 Hazelcast 支持的缓存实例的服务。

F¶

	控制器	描述
	FreeFormTextRecordSetWriter	将 RecordSet 的内容写入为自由格式文本。

G¶

	控制器	描述
	GCPCredentialsControllerService	定义 Google Cloud Platform 处理器的凭据。
	GCSFileResourceService	为其他组件提供 Google 计算存储 (GCS) 文件资源。
	GrokReader	提供一种机制，用于读取非结构化文本数据（如日志文件），并对这些数据进行结构化处理，以便能够进行处理。

H¶

	控制器	描述
	HazelcastMapCacheClient	使用 Hazelcast 作为后备缓存的 DistributedMapCacheClient 的实现。
	HikariCPConnectionPool	提供基于 HikariCP 的数据库连接池服务。
	HttpRecordSink (httprecordsink.html)	将记录格式化，然后通过 HTTP POST 的方式发送至配置的 URI。

I¶

	控制器	描述
	IPLookupService	一种为 IP 地址提供多种类型的丰富信息的查找服务。

J¶

	控制器	描述
	JettyWebSocketClient	WebSocketClientService 实现。
	JettyWebSocketServer	WebSocketServerService 实现。
	JMSConnectionFactoryProvider	提供用于创建供应商特定的 javax 的通用服务。
	JndiJmsConnectionFactoryProvider	提供使用 Java 命名和目录接口 (JNDI) 查找现有 JMS ConnectionFactory 的服务。
	JsonConfigBasedBoxClientService	提供 Box 客户端对象，通过这些对象可以使用 Box API 调用。
	JsonPathReader	解析 JSON 记录，并针对每个 JSON 对象评估用户定义的 JSON 路径。
	JsonRecordSetWriter	以 JSON 数组或每行一个 JSON 对象的形式写入 RecordSet 的结果
Snowflake	JsonTableColumnFilter	根据 JSON 配置提供表列筛选器。
	JsonTreeReader	将 JSON 解析为单个记录对象。
	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 Graph API 提供身份验证，可用于与 Microsoft 365 服务进行交互。
	MongoDBControllerService	提供控制器服务，用于配置与 MongoDB 的连接，并向其他 Mongo 相关组件提供对该连接的访问权限。
	MongoDBLookupService	提供基于 MongoDB 的查找服务。

P¶

	控制器	描述
Snowflake	ParquetIcebergWriter	使用 Apache Parquet 格式，为 Apache Iceberg 提供记录序列化
	PEMEncodedSSLContextProvider	SSLContext 提供程序可使用 PEM 私钥和证书文件进行配置。
Snowflake	PolarisIcebergCatalog	通过 REST HTTP 提供 Apache Iceberg 与 Apache Polaris Catalog 的访问集成
	PropertiesFileLookupService	一种可重载、基于属性文件的查找服务。

R¶

	控制器	描述
	ReaderLookup	提供可用于动态选择另一个 RecordReaderFactory 的 RecordReaderFactory。
	RecordSetWriterLookup	提供可用于动态选择另一个 RecordSetWriterFactory 的 RecordSetWriterFactory。
	RecordSinkServiceLookup	提供可用于动态选择另一个 RecordSinkService 的 RecordSinkService。
	RedisConnectionPoolService	提供与 Redis 的连接的服务。
	RedisDistributedMapCacheClientService	使用 Redis 作为后备缓存的 DistributedMapCacheClient 的实现。
	RestLookupService	使用 REST 服务来查找值。

S¶

	控制器	描述
	S3FileResourceService	为其他组件提供 Amazon Web Services (AWS) S3 文件资源。
Snowflake	SalesforceDataCloudOAuthTokenProvider	使用已配置的 OAuth2 访问令牌提供程序从 Salesforce 检索 OAuth2 访问令牌，并将该令牌转换为 Data Cloud API 令牌。
	ScriptedLookupService	允许用户提供脚本化 LookupService 实例，以便丰富传入 FlowFile 中的记录。
	ScriptedReader	允许用户提供脚本化 RecordReaderFactory 实例，以便从传入 FlowFile 中读取/解析/生成记录。
	ScriptedRecordSetWriter	允许用户提供脚本化 RecordSetWriterFactory 实例，以便将记录写入到传出 FlowFile。
	ScriptedRecordSink	允许用户提供脚本化 RecordSinkService 实例，以便将记录传输到所需的目标。
	SetCacheClientService	提供与 SetCacheServer 通信的功能。
	SetCacheServer	提供可通过套接字访问的集合（唯一值的集合）缓存。
	SimpleCsvFileLookupService	一种可重载、基于 CSV 文件的查找服务。
	SimpleDatabaseLookupService	一种基于关系数据库的查找服务。
	SimpleKeyValueLookupService	允许用户添加键/值对作为用户定义的属性。
	SimpleRedisDistributedMapCacheClientService	使用 Redis 作为后备缓存的 DistributedMapCacheClient 的实现。
	SimpleScriptedLookupService	允许用户提供脚本化 LookupService 实例，以便丰富传入 FlowFile 中的记录。
	SlackRecordSink	格式化记录，然后使用 Slack Post Message API 其发送到已配置的通道。
	SmbjClientProviderService	使用共享身份验证凭据提供对 SMB 会话的访问权限。
Snowflake	SnowflakeConnectionService	提供与 Snowflake 服务的池化数据库连接
Snowflake	SnowflakeDatabaseDialectService	支持 Snowflake 的数据库方言服务。
Snowflake	SnowflakeSignJWTService
Snowflake	SnowflakeTableSchemaRegistry
Snowflake	StandardAnthropicLLMService	一款控制器服务，可通过其消息 API 与 Anthropic 的 Claude AI 模型进行集成。
	StandardAzureCredentialsControllerService	提供用于 Azure 客户端的凭据。
Snowflake	StandardDatabricksWorkspaceClientService	Databricks 客户端。
	StandardDropboxCredentialService	定义 Dropbox 处理器的凭据。
	StandardFileResourceService	为其他组件提供文件资源。
	StandardHashiCorpVaultClientService	一种用于与 HashiCorp Vault 交互的控制器服务。
	StandardHttpContextMap	提供存储和检索处理器外部的 HTTP 请求和响应的功能，以便多个处理器可以与同一个 HTTP 请求进行交互。
Snowflake	StandardHubSpotClientService	要与 HubSpot HTTP API 集成的 HubSpot 控制器服务。
	StandardJsonSchemaRegistry	提供用于注册和访问 JSON 架构的服务。
	StandardKustoIngestService	将 FlowFile 内容或流式 FlowFile 内容批量发送到 Azure ADX 集群。
	StandardKustoQueryService	适用于 Azure 数据资源管理器的 Kusto 查询服务的标准实现
Snowflake	StandardMilvusConnectionService	提供连接到 Milvus 实例的服务
	StandardOauth2AccessTokenProvider	提供 OAuth 2。
Snowflake	StandardOCRService	提供与 Openflow OCR 服务的集成
Snowflake	StandardOpenAILLMService	提供与 OpenAI 的 Chat Completion API 集成的控制器服务。
	StandardPGPPrivateKeyService	PGP 私钥服务提供从文件或属性加载的私钥
	StandardPGPPublicKeyService	PGP 公钥服务，提供从文件加载的公钥
	StandardPrivateKeyService	私钥服务提供对从配置源加载的私钥的访问权限
	StandardProxyConfigurationService	为不同的 NiFi 组件提供一组配置，以使用代理服务器。
	StandardRestrictedSSLContextService	SSLContextService 的实现受到限制。
	StandardS3EncryptionService	为 S3 写入和 S3 提取操作添加可配置的加密功能。
Snowflake	StandardSalesforceClientService	提供与 Salesforce APIs 的连接服务
Snowflake	StandardSalesforceDataCloudClientService	提供连接到 Salesforce Data Cloud APIs 的服务
	StandardSSLContextService	SSLContextService 的标准实现。
Snowflake	StandardTableStateService	提供和管理表状态的控制器服务。
Snowflake	StandardVectaraClientService	要与 Vectara HTTP API 集成的 Vectara 控制器服务。
	StandardWebClientServiceProvider	支持配置标准 HTTP 连接属性的 Web 客户端服务提供商
Snowflake	StateManagedCdcSchemaRegistry	使用内置的 NiFi 状态管理来存储表架构的哈希值。
	Syslog5424Reader	提供了一种机制，用于读取符合 RFC 5424 的 Syslog 数据（例如日志文件），并对数据进行结构化以便对其进行处理。
	SyslogReader	尝试根据 RFC5424 和 RFC3164 解析 Syslog 消息的内容。

U¶

	控制器	描述
	UDPEventRecordSink	格式化记录并将其作为 UDP 数据报包发送到可配置的目的地

V¶

	控制器	描述
	VolatileSchemaCache	提供基于“最近最少使用”算法淘汰元素的架构缓存。

W¶

	控制器	描述
	WindowsEventLogReader	将 Windows 事件日志数据读取为由 ConsumeWindowsEventLog、ParseEvtx 等生成的 XML 内容。

X¶

	控制器	描述
	XMLFileLookupService	一种可重载、基于 XML 文件的查找服务。
	XMLReader	读取 XML 内容并创建 Record 对象。
	XMLRecordSetWriter	将 RecordSet 写入 XML。

Y¶

	控制器	描述
	YamlTreeReader	将 YAML 解析为单个记录对象。