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 |
|
---|---|---|
Define as credenciais para os processadores ADLS. |
||
Fornece um ADLSCredentialsService que pode ser usado para selecionar dinamicamente outro ADLSCredentialsService. |
||
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. |
||
Fornece e gerencia conexões com o AWS MSK Kafka Brokers para operações de produtor ou consumidor. |
||
Snowflake |
Fornece e gerencia conexões com o AWS MSK Kafka Brokers para operações de produtor ou consumidor. |
|
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. |
||
Analisa os dados do Avro e retorna cada registro do Avro como um objeto de registro separado. |
||
Grava o conteúdo de um RecordSet no formato Avro binário. |
||
Fornece um serviço para registro de esquemas e acesso a eles. |
||
Define as credenciais para os processadores do Amazon Web Services. |
||
Fornece um recurso de arquivo do Armazenamento de Blobs do Azure para outros componentes. |
||
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. |
||
Fornece um recurso de arquivo do Azure Data Lake Storage (ADLS) para outros componentes. |
||
Formata e envia os registros para os Hubs de Eventos do Azure |
||
Fornece credenciais para processadores do armazenamento do Azure usando a biblioteca de clientes do Armazenamento do Azure v12. |
||
Fornece um AzureStorageCredentialsService_v12 que pode ser usado para selecionar dinamicamente outro AzureStorageCredentialsService_v12. |
C¶
Controlador |
Descrição |
|
---|---|---|
Analisa os eventos de formato comum de evento (CEF) retornando cada linha como um registro. |
||
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 |
||
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 |
||
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. |
||
Analisa os dados formatados em CSV, retornando cada linha do arquivo CSV como um registro separado. |
||
Um serviço de pesquisa recarregável baseado em arquivo CSV. |
||
Grava o conteúdo de um RecordSet como dados CSV. |
D¶
Controlador |
Descrição |
|
---|---|---|
Snowflake |
Um serviço de pesquisa que permite o enriquecimento com um banco de dados usando uma instrução SQL especificada pelo usuário. |
|
Um serviço de pesquisa baseado em banco de dados relacional. |
||
Fornece um serviço para gravar registros usando uma conexão de banco de dados configurada. |
||
Fornece o serviço de pool de conexões de banco de dados. |
||
Fornece um DBCPService que pode ser usado para selecionar dinamicamente outro DBCPService. |
||
Fornece objetos de cliente Box por meio dos quais as chamadas da Box API podem ser usadas. |
||
Permite escolher um cliente de cache de mapa distribuído para recuperar o valor associado a uma chave. |
E¶
Controlador |
Descrição |
|
---|---|---|
Um serviço de controlador para acessar um cliente Elasticsearch, usando o Elasticsearch (baixo nível) cliente REST. |
||
Procure um registro do Elasticsearch Server associado ao ID do documento especificado. |
||
Procure um valor de cadeia de caracteres do Elasticsearch Server associado ao ID do documento especificado. |
||
Fornece um RecordSinkService que pode ser usado para enviar registros por e-mail usando o gravador especificado para formatação. |
||
Um serviço que executa o Hazelcast incorporado e fornece instâncias de cache suportadas por ele. |
||
Analisa um documento do Microsoft Excel, retornando cada linha em cada planilha como um registro separado. |
||
Um serviço que fornece instâncias de cache apoiadas pelo Hazelcast em execução fora do NiFi. |
F¶
Controlador |
Descrição |
|
---|---|---|
Grava o conteúdo de um RecordSet como texto de forma livre. |
G¶
Controlador |
Descrição |
|
---|---|---|
Define as credenciais para os processadores do Google Cloud Platform. |
||
Fornece um recurso de arquivo do Google Compute Storage (GCS) para outros componentes. |
||
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 |
|
---|---|---|
Uma implementação do DistributedMapCacheClient que usa o Hazelcast como cache de apoio. |
||
Fornece um serviço de pool de conexões com banco de dados baseado no HikariCP. |
||
Formate e envie registros para um URI configurado usando POST de HTTP. |
I¶
Controlador |
Descrição |
|
---|---|---|
Um serviço de pesquisa que fornece vários tipos de informações de enriquecimento para endereços IP. |
J¶
Controlador |
Descrição |
|
---|---|---|
Implementação de WebSocketClientService. |
||
Implementação de WebSocketServerService. |
||
Fornece um serviço genérico para criar javax específicos de fornecedor. |
||
Fornece um serviço para pesquisar um JMS ConnectionFactory existente usando a interface de nomes e diretórios do Java (JNDI). |
||
Fornece objetos de cliente Box por meio dos quais as chamadas da Box API podem ser usadas. |
||
Analisa os registros JSON e avalia os caminhos JSON definidos pelo usuário em relação a cada objeto JSON. |
||
Grava os resultados de um RecordSet como uma matriz JSON ou um objeto JSON por linha. |
||
Snowflake |
Fornece um filtro de coluna de tabela com base em uma configuração do JSON. |
|
Analisa JSON em objetos de registro individuais. |
||
Fornece OAuth 2. |
K¶
Controlador |
Descrição |
|
---|---|---|
Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor. |
||
Snowflake |
Fornece e gerencia conexões com os corretores Kafka para operações de produtor ou consumidor. |
L¶
Controlador |
Descrição |
|
---|---|---|
Fornece um RecordSinkService que pode ser usado para gravar os registros no log do aplicativo (nifi-app. |
M¶
Controlador |
Descrição |
|
---|---|---|
Oferece a capacidade de se comunicar com um MapCacheServer. |
||
Fornece um cache de mapa (chave/valor) que pode ser acessado por meio de um soquete. |
||
Snowflake |
Fornece tokens de acesso OAuth2 para a Microsoft Graph API usando client_credentials com um certificado de cliente. |
|
Snowflake |
Fornece autenticação para a Microsoft Graph API, que pode ser usada para interagir com os serviços do Microsoft 365. |
|
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. |
||
Fornece um serviço de pesquisa baseado em MongoDB. |
P¶
Controlador |
Descrição |
|
---|---|---|
Snowflake |
Fornece serialização de registros ao Apache Iceberg usando a formatação do Apache Parquet |
|
Provedor de SSLContext configurável por meio dos arquivos PEM de chave privada e certificado. |
||
Snowflake |
Fornece integração do Apache Iceberg com o acesso ao catálogo do Apache Polaris por meio de REST HTTP |
|
Um serviço de pesquisa baseado em arquivo de propriedades recarregável |
R¶
Controlador |
Descrição |
|
---|---|---|
Fornece um RecordReaderFactory que pode ser usado para selecionar dinamicamente outro RecordReaderFactory. |
||
Fornece um RecordSetWriterFactory que pode ser usado para selecionar dinamicamente outro RecordSetWriterFactory. |
||
Fornece um RecordSinkService que pode ser usado para selecionar dinamicamente outro RecordSinkService. |
||
Um serviço que fornece conexões com o Redis. |
||
Uma implementação do DistributedMapCacheClient que usa o Redis como cache de apoio. |
||
Use um serviço REST para procurar valores. |
S¶
Controlador |
Descrição |
|
---|---|---|
Fornece um recurso de arquivo S3 do Amazon Web Services (AWS) para outros componentes. |
||
Snowflake |
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. |
|
Permite que o usuário forneça uma instância LookupService com script para enriquecer os registros de um FlowFile de entrada. |
||
Permite que o usuário forneça uma instância de RecordReaderFactory com script para ler/analisar/gerar registros de um FlowFile de entrada. |
||
Permite que o usuário forneça uma instância de RecordSetWriterFactory com script para gravar registros em um FlowFile de saída. |
||
Permite que o usuário forneça uma instância de RecordSinkService com script para transmitir registros para o destino desejado. |
||
Oferece a capacidade de se comunicar com um SetCacheServer. |
||
Fornece um cache de conjunto (coleção de valores exclusivos) que pode ser acessado por meio de um soquete. |
||
Um serviço de pesquisa recarregável baseado em arquivo CSV. |
||
Um serviço de pesquisa baseado em banco de dados relacional. |
||
Permite que os usuários adicionem pares chave-valor como propriedades definidas pelo usuário. |
||
Uma implementação do DistributedMapCacheClient que usa o Redis como cache de apoio. |
||
Permite que o usuário forneça uma instância LookupService com script para enriquecer os registros de um FlowFile de entrada. |
||
Formate e envie registros para um canal configurado usando a Slack Post Message API. |
||
Fornece acesso a sessões SMB com credenciais de autenticação compartilhadas. |
||
Snowflake |
Fornece conexões de banco de dados em pool para os serviços Snowflake |
|
Snowflake |
Serviço de dialeto de banco de dados compatível com o Snowflake. |
|
Snowflake |
||
Snowflake |
||
Snowflake |
Um Controller Service que fornece integração com os modelos Claude AI da Anthropic por meio de sua API de mensagens. |
|
Forneça credenciais para usar com um cliente Azure. |
||
Snowflake |
Cliente Databricks. |
|
Define as credenciais para os processadores do Dropbox. |
||
Fornece um recurso de arquivo para outros componentes. |
||
Um serviço de controlador para interagir com o HashiCorp Vault. |
||
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 |
Controller Service HubSpot para integração com a HubSpot HTTP API. |
|
Fornece um serviço para registro e acesso a esquemas JSON. |
||
Envia lotes de conteúdo de FlowFile ou conteúdo de FlowFile de fluxo para um cluster ADX do Azure. |
||
Implementação padrão do Kusto Query Service para o Azure Data Explorer |
||
Snowflake |
Fornece serviço de conexão para uma instância do Milvus |
|
Fornece OAuth 2. |
||
Snowflake |
Oferece integração com o Openflow OCR Service |
|
Snowflake |
Um Controller Service que fornece integração com a API de conclusão de conversas da OpenAI. |
|
O serviço de chave privada PGP que fornece chaves privadas carregadas de arquivos ou propriedades |
||
O serviço de chave pública PGP que fornece chaves públicas carregadas de arquivos |
||
O serviço de chave privada que fornece acesso a uma chave privada carregada de fontes configuradas |
||
Fornece um conjunto de configurações para que diferentes componentes do NiFi usem um servidor proxy. |
||
Implementação restrita do SSLContextService. |
||
Adiciona criptografia configurável às operações de envio (Put) e busca (Fetch) no S3. |
||
Snowflake |
Fornece serviço de conexão para as APIs Salesforce |
|
Snowflake |
Fornece serviço de conexão com as Salesforce Data Cloud APIs |
|
Implementação padrão do SSLContextService. |
||
Snowflake |
Um Controller Service que fornece e gerencia o estado da tabela. |
|
Snowflake |
O Controller Service do Vectara para integração com a Vectara HTTP API. |
|
Provedor de serviços de cliente Web com suporte para configurar as propriedades de conexão HTTP padrão |
||
Snowflake |
Usa o gerenciamento de estados do NiFi incorporado para armazenar hashes dos esquemas de tabela. |
|
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. |
||
Tenta analisar o conteúdo de uma mensagem do Syslog de acordo com a RFC5424 e RFC3164. |
U¶
Controlador |
Descrição |
|
---|---|---|
Formata e envia registros como pacotes de datagrama UDP para um destino configurável |
V¶
Controlador |
Descrição |
|
---|---|---|
Fornece um cache de esquema que despeja elementos com base em um algoritmo Least-Recently-Used. |
W¶
Controlador |
Descrição |
|
---|---|---|
Lê os dados do registro de eventos do Windows como conteúdo XML gerado por ConsumeWindowsEventLog, ParseEvtx etc. |
X¶
Controlador |
Descrição |
|
---|---|---|
Um serviço de pesquisa recarregável baseado em arquivo XML. |
||
Lê o conteúdo do XML e cria objetos de registro. |
||
Grava um RecordSet em XML. |
Y¶
Controlador |
Descrição |
|
---|---|---|
Analisa YAML em objetos de registro individuais. |