Todos os controladores (em ordem alfabética)

Este tópico fornece uma lista de todos os controladores de fluxo aberto em ordem alfabética. A lista inclui:

  • Tipo de controlador (Snowflake ou não)

  • O nome de cada controlador

  • Um resumo de cada controlador

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.

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.

Snowflake

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 serviço de controlador que configura uma conexão com o Cosmos DB (Core SQL API) 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

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

Snowflake

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 os registros JSON e avalia os 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.

Snowflake

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.

Snowflake

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.

Snowflake

MicrosoftClientCertificateOAuth2TokenProvider

Fornece tokens de acesso OAuth2 para a Microsoft Graph API usando client_credentials com um certificado de cliente.

Snowflake

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

Snowflake

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.

Snowflake

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

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.

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.

Snowflake

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.

Snowflake

SnowflakeConnectionService

Fornece conexões de banco de dados em pool para os serviços Snowflake

Snowflake

SnowflakeDatabaseDialectService

Serviço de dialeto de banco de dados compatível com o Snowflake.

Snowflake

SnowflakeSignJWTService

Snowflake

SnowflakeTableSchemaRegistry

Snowflake

StandardAnthropicLLMService

Um Controller Service que fornece integração com os modelos Claude AI da Anthropic por meio de sua API de mensagens.

StandardAzureCredentialsControllerService

Forneça credenciais para usar com um cliente Azure.

Snowflake

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.

Snowflake

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

Snowflake

StandardMilvusConnectionService

Fornece serviço de conexão para uma instância do Milvus

StandardOauth2AccessTokenProvider

Fornece OAuth 2.

Snowflake

StandardOCRService

Oferece integração com o Openflow OCR Service

Snowflake

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

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.

Snowflake

StandardSalesforceClientService

Fornece serviço de conexão para as APIs Salesforce

Snowflake

StandardSalesforceDataCloudClientService

Fornece serviço de conexão com as Salesforce Data Cloud APIs

StandardSSLContextService

Implementação padrão do SSLContextService.

Snowflake

StandardTableStateService

Um Controller Service que fornece e gerencia o estado da tabela.

Snowflake

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

Snowflake

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.