Todos os Controller Services (em ordem alfabética)¶

Este tópico fornece uma lista de todos os Controller Services do Openflow em ordem alfabética. A lista inclui:

Tipo de Controller Service (Snowflake ou não)

O nome de cada Controller Service

Um resumo de cada Controller Service

A¶

	Controlador	Descrição
	ADLSCredentialsControllerService	Define as credenciais para os processadores ADLS.
	ADLSCredentialsControllerServiceLookup	Fornece um ADLSCredentialsService que pode ser usado para selecionar dinamicamente outro ADLSCredentialsService.
	AmazonGlueEncodedSchemaReferenceReader	Lê o identificador de esquema de acordo com a codificação do esquema AWS Glue como um cabeçalho composto por marcadores de dois bytes e um UUID de 16 bytes.
	AmazonGlueSchemaRegistry	Fornece um registro de esquema que interage com o AWS Glue Schema Registry para que os esquemas armazenados no Glue Schema Registry possam ser usados no NiFi.
	AmazonMSKConnectionService	Fornece e gerencia conexões com o AWS MSK Kafka Brokers para operações de produtor ou consumidor.
	AmazonMSKConnectionService	Fornece e gerencia conexões com o AWS MSK Kafka Brokers para operações de produtor ou consumidor.
	ApicurioSchemaRegistry	Fornece um registro de esquema que interage com o Apicurio Schema Registry para que os esquemas armazenados no Apicurio Schema Registry possam ser usados no NiFi.
	AvroReader	Analisa os dados do Avro e retorna cada registro do Avro como um objeto de registro separado.
	AvroRecordSetWriter	Grava o conteúdo de um RecordSet no formato Avro binário.
	AvroSchemaRegistry	Fornece um serviço para registro de esquemas e acesso a eles.
	AWSCredentialsProviderControllerService	Define as credenciais para os processadores do Amazon Web Services.
	AzureBlobStorageFileResourceService	Fornece um recurso de arquivo do Armazenamento de Blobs do Azure para outros componentes.
	AzureCosmosDBClientService	Fornece um Controller Service que configura uma conexão com o Cosmos DB (API Core SQL) e fornece acesso a essa conexão para outros componentes relacionados ao Cosmos DB.
	AzureDataLakeStorageFileResourceService	Fornece um recurso de arquivo do Azure Data Lake Storage (ADLS) para outros componentes.
	AzureEventHubRecordSink	Formata e envia os registros para os Hubs de Eventos do Azure
	AzureStorageCredentialsControllerService_v12	Fornece credenciais para processadores do armazenamento do Azure usando a biblioteca de clientes do Armazenamento do Azure v12.
	AzureStorageCredentialsControllerServiceLookup_v12	Fornece um AzureStorageCredentialsService_v12 que pode ser usado para selecionar dinamicamente outro AzureStorageCredentialsService_v12.

C¶

	Controlador	Descrição
	CEFReader	Analisa os eventos de formato comum de evento (CEF) retornando cada linha como um registro.
	ConfluentEncodedSchemaReferenceReader	Lê o identificador de esquema de acordo com a codificação Confluent como um cabeçalho que consiste em um marcador de bytes e um número inteiro representado como quatro bytes
	ConfluentEncodedSchemaReferenceWriter	Grava o identificador de esquema de acordo com a codificação Confluent como um cabeçalho que consiste em um marcador de bytes e um número inteiro representado como quatro bytes
	ConfluentProtobufMessageNameResolver	Resolve nomes de mensagens Protobuf do formato de conexão do Confluent Schema Registry decodificando índices de mensagens e pesquisando o nome totalmente qualificado na definição do esquema. Para obter uma referência do formato de conexão do Confluent, consulte: https://docs.
	ConfluentSchemaRegistry	Fornece um registro de esquema que interage com o Confluent Schema Registry para que os esquemas armazenados no Confluent Schema Registry possam ser usados no NiFi.
	CSVReader	Analisa os dados formatados em CSV, retornando cada linha do arquivo CSV como um registro separado.
	CSVRecordLookupService	Um serviço de pesquisa recarregável baseado em arquivo CSV.
	CSVRecordSetWriter	Grava o conteúdo de um RecordSet como dados CSV.

D¶

	Controlador	Descrição
	DatabaseLookup	Um serviço de pesquisa que permite o enriquecimento com um banco de dados usando uma instrução SQL especificada pelo usuário.
	DatabaseRecordLookupService	Um serviço de pesquisa baseado em banco de dados relacional.
	DatabaseRecordSink	Fornece um serviço para gravar registros usando uma conexão de banco de dados configurada.
	DBCPConnectionPool	Fornece o serviço de pool de conexões de banco de dados.
	DBCPConnectionPoolLookup	Fornece um DBCPService que pode ser usado para selecionar dinamicamente outro DBCPService.
	DeveloperBoxClientService	Fornece objetos de cliente Box por meio dos quais as chamadas da Box API podem ser usadas.
	DistributedMapCacheLookupService	Permite escolher um cliente de cache de mapa distribuído para recuperar o valor associado a uma chave.

E¶

	Controlador	Descrição
	ElasticSearchClientServiceImpl	Um serviço de controlador para acessar um cliente Elasticsearch, usando o Elasticsearch (baixo nível) cliente REST.
	ElasticSearchLookupService	Procure um registro do Elasticsearch Server associado ao ID do documento especificado.
	ElasticSearchStringLookupService	Procure um valor de cadeia de caracteres do Elasticsearch Server associado ao ID do documento especificado.
	EmailRecordSink	Fornece um RecordSinkService que pode ser usado para enviar registros por e-mail usando o gravador especificado para formatação.
	EmbeddedHazelcastCacheManager	Um serviço que executa o Hazelcast incorporado e fornece instâncias de cache suportadas por ele.
	ExcelReader	Analisa um documento do Microsoft Excel, retornando cada linha em cada planilha como um registro separado.
	ExternalHazelcastCacheManager	Um serviço que fornece instâncias de cache apoiadas pelo Hazelcast em execução fora do NiFi.

F¶

	Controlador	Descrição
	FreeFormTextRecordSetWriter	Grava o conteúdo de um RecordSet como texto de forma livre.

G¶

	Controlador	Descrição
	GCPCredentialsControllerService	Define as credenciais para os processadores do Google Cloud Platform.
	GCSFileResourceService	Fornece um recurso de arquivo do Google Compute Storage (GCS) para outros componentes.
	GrokReader	Fornece um mecanismo para ler dados de texto não estruturados, como arquivos de registro, e estruturar os dados para que possam ser processados.

H¶

	Controlador	Descrição
	HazelcastMapCacheClient	Uma implementação do DistributedMapCacheClient que usa o Hazelcast como cache de apoio.
	HikariCPConnectionPool	Fornece um serviço de pool de conexões com banco de dados baseado no HikariCP.
	HttpRecordSink	Formate e envie registros para um URI configurado usando POST de HTTP.

I¶

	Controlador	Descrição
	IPLookupService	Um serviço de pesquisa que fornece vários tipos de informações de enriquecimento para endereços IP.

J¶

	Controlador	Descrição
	JettyWebSocketClient	Implementação de WebSocketClientService.
	JettyWebSocketServer	Implementação de WebSocketServerService.
	JMSConnectionFactoryProvider	Fornece um serviço genérico para criar javax específicos de fornecedor.
	JndiJmsConnectionFactoryProvider	Fornece um serviço para pesquisar um JMS ConnectionFactory existente usando a interface de nomes e diretórios do Java (JNDI).
	JsonConfigBasedBoxClientService	Fornece objetos de cliente Box por meio dos quais as chamadas da Box API podem ser usadas.
	JsonPathReader	Analisa registros JSON e avalia caminhos JSON definidos pelo usuário em relação a cada objeto JSON.
	JsonRecordSetWriter	Grava os resultados de um RecordSet como uma matriz JSON ou um objeto JSON por linha.
	JsonTableColumnFilter	Fornece um filtro de coluna de tabela com base em uma configuração do JSON.
	JsonTreeReader	Analisa JSON em objetos de registro individuais.
	JWTBearerOAuth2AccessTokenProvider	Fornece OAuth 2.

K¶

	Controlador	Descrição
	Kafka3ConnectionService	Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor.
	Kafka3ConnectionService	Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor.

L¶

	Controlador	Descrição
	LoggingRecordSink	Fornece um RecordSinkService que pode ser usado para gravar os registros no log do aplicativo (nifi-app.

M¶

	Controlador	Descrição
	MapCacheClientService	Oferece a capacidade de se comunicar com um MapCacheServer.
	MapCacheServer	Fornece um cache de mapa (chave/valor) que pode ser acessado por meio de um soquete.
	MicrosoftClientCertificateOAuth2TokenProvider	Fornece tokens de acesso OAuth2 para a Microsoft Graph API usando client_credentials com um certificado de cliente.
	MicrosoftGraphAuthenticationProvider	Fornece autenticação para a Microsoft Graph API, que pode ser usada para interagir com os serviços do Microsoft 365.
	MongoDBControllerService	Fornece um serviço de controlador que configura uma conexão com MongoDB e fornece acesso a essa conexão para outros componentes relacionados ao Mongo.
	MongoDBLookupService	Fornece um serviço de pesquisa baseado em MongoDB.

P¶

	Controlador	Descrição
	ParquetIcebergWriter	Fornece serialização de registros ao Apache Iceberg usando a formatação do Apache Parquet
	PEMEncodedSSLContextProvider	Provedor de SSLContext configurável por meio dos arquivos PEM de chave privada e certificado.
	PolarisIcebergCatalog	Fornece integração do Apache Iceberg com o acesso ao catálogo do Apache Polaris por meio de REST HTTP
	PropertiesFileLookupService	Um serviço de pesquisa baseado em arquivo de propriedades recarregável
	ProtobufReader	Analisa uma mensagem Protocol Buffers do formato binário.

R¶

	Controlador	Descrição
	ReaderLookup	Fornece um RecordReaderFactory que pode ser usado para selecionar dinamicamente outro RecordReaderFactory.
	RecordSetWriterLookup	Fornece um RecordSetWriterFactory que pode ser usado para selecionar dinamicamente outro RecordSetWriterFactory.
	RecordSinkServiceLookup	Fornece um RecordSinkService que pode ser usado para selecionar dinamicamente outro RecordSinkService.
	RedisConnectionPoolService	Um serviço que fornece conexões com o Redis.
	RedisDistributedMapCacheClientService	Uma implementação do DistributedMapCacheClient que usa o Redis como cache de apoio.
	RemoveFieldRecordReader	Um wrapper para uma RecordReaderFactory que oferece suporte à filtragem de campos especificados de registros NiFi.
	RestLookupService	Use um serviço REST para procurar valores.

S¶

	Controlador	Descrição
	S3FileResourceService	Fornece um recurso de arquivo S3 do Amazon Web Services (AWS) para outros componentes.
	SalesforceDataCloudOAuthTokenProvider	Recupera um token de acesso OAuth2 do Salesforce usando o provedor de token de acesso OAuth2 configurado e troca o token por um token da Data Cloud API.
	ScriptedLookupService	Permite que o usuário forneça uma instância LookupService com script para enriquecer os registros de um FlowFile de entrada.
	ScriptedReader	Permite que o usuário forneça uma instância de RecordReaderFactory com script para ler/analisar/gerar registros de um FlowFile de entrada.
	ScriptedRecordSetWriter	Permite que o usuário forneça uma instância de RecordSetWriterFactory com script para gravar registros em um FlowFile de saída.
	ScriptedRecordSink	Permite que o usuário forneça uma instância de RecordSinkService com script para transmitir registros para o destino desejado.
	SetCacheClientService	Oferece a capacidade de se comunicar com um SetCacheServer.
	SetCacheServer	Fornece um cache de conjunto (coleção de valores exclusivos) que pode ser acessado por meio de um soquete.
	SimpleCsvFileLookupService	Um serviço de pesquisa recarregável baseado em arquivo CSV.
	SimpleDatabaseLookupService	Um serviço de pesquisa baseado em banco de dados relacional.
	SimpleKeyValueLookupService	Permite que os usuários adicionem pares chave-valor como propriedades definidas pelo usuário.
	SimpleRedisDistributedMapCacheClientService	Uma implementação do DistributedMapCacheClient que usa o Redis como cache de apoio.
	SimpleScriptedLookupService	Permite que o usuário forneça uma instância LookupService com script para enriquecer os registros de um FlowFile de entrada.
	SlackRecordSink	Formate e envie registros para um canal configurado usando a Slack Post Message API.
	SmbjClientProviderService	Fornece acesso a sessões SMB com credenciais de autenticação compartilhadas.
	SnowflakeConnectionService	Fornece conexões de banco de dados em pool para os serviços Snowflake
	SnowflakeDatabaseDialectService	Serviço de dialeto de banco de dados compatível com o Snowflake.
	SnowflakeSignJWTService	Fornece o token de acesso OAuth2 usando um JWT assinado com um segredo armazenado no Snowflake.
	SnowflakeTableSchemaRegistry	Usa tabelas Snowflake como origem do esquema. Utiliza a API REST do Snowpipe Streaming.
	StandardAnthropicLLMService	Um Controller Service que fornece integração com os modelos Claude AI da Anthropic por meio de sua API de mensagens.
	StandardAtlassianRequestRateManager	Fornece coordenação de limitação de taxa para chamadas de API da Atlassian entre processadores para evitar problemas de limitação de taxa em cascata.
	StandardAzureCredentialsControllerService	Forneça credenciais para usar com um cliente Azure.
	StandardConfluenceClientService	Fornece serviço de conexão para APIs Confluence
	StandardDatabricksWorkspaceClientService	Cliente Databricks.
	StandardDropboxCredentialService	Define as credenciais para os processadores do Dropbox.
	StandardFileResourceService	Fornece um recurso de arquivo para outros componentes.
	StandardHashiCorpVaultClientService	Um serviço de controlador para interagir com o HashiCorp Vault.
	StandardHttpContextMap	Oferece a capacidade de armazenar e recuperar solicitações e respostas HTTP externas a um processador, de modo que vários processadores possam interagir com a mesma solicitação HTTP.
	StandardHubSpotClientService	Controller Service HubSpot para integração com a HubSpot HTTP API.
	StandardJsonSchemaRegistry	Fornece um serviço para registro e acesso a esquemas JSON.
	StandardKustoIngestService	Envia lotes de conteúdo de FlowFile ou conteúdo de FlowFile de fluxo para um cluster ADX do Azure.
	StandardKustoQueryService	Implementação padrão do Kusto Query Service para o Azure Data Explorer
	StandardMilvusConnectionService	Fornece serviço de conexão para uma instância do Milvus
	StandardOauth2AccessTokenProvider	Fornece OAuth 2.
	StandardOCRService	Oferece integração com o Openflow OCR Service
	StandardOpenAILLMService	Um Controller Service que fornece integração com a API de conclusão de conversas da OpenAI.
	StandardPGPPrivateKeyService	O serviço de chave privada PGP que fornece chaves privadas carregadas de arquivos ou propriedades
	StandardPGPPublicKeyService	O serviço de chave pública PGP que fornece chaves públicas carregadas de arquivos
	StandardPrivateKeyService	O serviço de chave privada que fornece acesso a uma chave privada carregada de fontes configuradas
	StandardProtobufReader	Analisa mensagens do Protocol Buffers do formato binário para registros NiFi.
	StandardProxyConfigurationService	Fornece um conjunto de configurações para que diferentes componentes do NiFi usem um servidor proxy.
	StandardRestrictedSSLContextService	Implementação restrita do SSLContextService.
	StandardS3EncryptionService	Adiciona criptografia configurável às operações de envio (Put) e busca (Fetch) no S3.
	StandardSalesforceBulkJobsStateService	Armazena o estado dos trabalhos em massa do Salesforce por tipo de objeto no escopo do cluster
	StandardSalesforceClientService	Fornece serviço de conexão para as APIs Salesforce
	StandardSalesforceDataCloudClientService	Fornece serviço de conexão com as Salesforce Data Cloud APIs
	StandardSlackRateLimiterService	Fornece coordenação de limitação de taxa para chamadas de API do Slack entre processadores para evitar problemas de limite de taxa em cascata
	StandardSSLContextService	Implementação padrão do SSLContextService.
	StandardTableStateService	Um Controller Service que fornece e gerencia o estado da tabela.
	StandardVectaraClientService	O Controller Service do Vectara para integração com a Vectara HTTP API.
	StandardWebClientServiceProvider	Provedor de serviços de cliente Web com suporte para configurar as propriedades de conexão HTTP padrão
	StateManagedCdcSchemaRegistry	Usa o gerenciamento de estados do NiFi incorporado para armazenar hashes dos esquemas de tabela.
	Syslog5424Reader	Fornece um mecanismo para leitura de dados Syslog compatíveis com a RFC 5424, como arquivos de registro, e estruturação dos dados para que podem ser processados.
	SyslogReader	Tenta analisar o conteúdo de uma mensagem do Syslog de acordo com a RFC5424 e RFC3164.

U¶

	Controlador	Descrição
	UDPEventRecordSink	Formata e envia registros como pacotes de datagrama UDP para um destino configurável

V¶

	Controlador	Descrição
	VolatileSchemaCache	Fornece um cache de esquema que despeja elementos com base em um algoritmo Least-Recently-Used.

W¶

	Controlador	Descrição
	WindowsEventLogReader	Lê os dados do registro de eventos do Windows como conteúdo XML gerado por ConsumeWindowsEventLog, ParseEvtx etc.

X¶

	Controlador	Descrição
	XMLFileLookupService	Um serviço de pesquisa recarregável baseado em arquivo XML.
	XMLReader	Lê o conteúdo do XML e cria objetos de registro.
	XMLRecordSetWriter	Grava um RecordSet em XML.

Y¶

	Controlador	Descrição
	YamlTreeReader	Analisa YAML em objetos de registro individuais.