Todos os processadores (em ordem alfabética)¶

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

O nome de cada processador

Um resumo de cada processador

A¶

	Processador	Descrição
Snowflake	AbortQueryJob	Aborta um trabalho de consulta no Salesforce usando a Bulk API 2.
	AttributesToCSV	Gera uma representação CSV dos atributos FlowFile de entrada.
	AttributesToJSON	Gera uma representação JSON dos atributos FlowFile de entrada.

C¶

	Processador	Descrição
	CalculateRecordStats	Conta o número de registros em um conjunto de registros, opcionalmente contando o número de elementos por categoria, em que as categorias são definidas por propriedades definidas pelo usuário.
Snowflake	CaptureChangeMySQL	Lê eventos CDC de um banco de dados MySQL.
Snowflake	CaptureChangePostgreSQL	Lê eventos CDC de um banco de dados PostgreSQL.
Snowflake	CaptureChangeSqlServer	Lê eventos CDC de um banco de dados do servidor SQL.
Snowflake	CaptureGoogleDriveChanges	Captura alterações em um Google Drive compartilhado e emite um FlowFile para cada alteração ocorrida.
Snowflake	CaptureMicrosoft365GroupsChanges	Captura alterações de grupos do Microsoft365 e emite um FlowFile para cada alteração ocorrida.
Snowflake	CaptureSharepointChanges	Captura alterações de uma biblioteca de documentos do Sharepoint e emite um FlowFile para cada alteração ocorrida.
Snowflake	CheckMetaAdsReportReadiness	Processador verificando se o relatório do Meta Ads está pronto para download.
Snowflake	ChunkRecordText	Divide o texto em partes com opções para divisão recursiva por delimitadores e comprimento máximo de caracteres.
Snowflake	ChunkText	Divide o texto em partes com opções para divisão recursiva por delimitadores e comprimento máximo de caracteres.
	CompressContent	Comprime ou descomprime o conteúdo dos FlowFiles usando um algoritmo de compressão especificado pelo usuário e atualiza o mime.
	ConnectWebSocket	Atua como um ponto de extremidade do cliente WebSocket para interagir com um servidor WebSocket remoto.
	ConsumeAMQP	Consome mensagens AMQP de um corretor AMQP usando o AMQP 0.
	ConsumeAzureEventHub	Recebe mensagens dos Hubs de Eventos do Microsoft Azure com criação de pontos de verificação para garantir o processamento consistente de eventos.
	ConsumeBoxEnterpriseEvents	Consome eventos corporativos do tipo de fluxo admin_logs_streaming Box.
	ConsumeBoxEvents	Consome todos os eventos do Box.
	ConsumeElasticsearch	Um processador que executa repetidamente uma consulta paginada em um campo usando uma consulta Range para consumir novos documentos de um índice/consulta do Elasticsearch.
	ConsumeGCPubSub	Consome mensagens da assinatura configurada do Google Cloud PubSub.
	ConsumeIMAP	Consome mensagens do servidor de e-mail usando o protocolo IMAP.
	ConsumeJMS	Consome mensagem JMS do tipo BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage transformando seu conteúdo em um FlowFile e fazendo a transição para a relação “success”.
	ConsumeKafka	Consome mensagens da Apache Kafka Consumer API.
Snowflake	ConsumeKafka	Consome mensagens da Apache Kafka Consumer API.
	ConsumeKinesisStream	Lê dados do fluxo especificado do AWS Kinesis e gera um FlowFile para cada registro processado (bruto) ou um FlowFile para um lote de registros processados se um Record Reader e um Record Writer estiverem configurados.
	ConsumeMQTT	Assina um tópico e recebe mensagens de um corretor MQTT
	ConsumePOP3	Consome mensagens do servidor de e-mail usando o protocolo POP3.
	ConsumeSlack	Recupera mensagens de um ou mais canais configurados do Slack.
Snowflake	ConsumeSlackConversation	Recupera mensagens de conversas do Slack disponíveis para o aplicativo.
Snowflake	ConsumeSlackHistory	Obtém mensagens históricas de todos os canais Slack disponíveis para o aplicativo.
Snowflake	ConsumeSnowflakeStream	Obtém dados de um fluxo Snowflake e os grava em FlowFile.
	ConsumeTwitter	Transmite tweets do streaming da API v2 de streaming do Twitter.
	ControlRate	Controla a taxa na qual os dados são transferidos para os processadores subsequentes.
	ConvertCharacterSet	Converta o conteúdo do FlowFile de um conjunto de caracteres para outro
	ConvertRecord	Converte registros de um formato de dados para outro usando os Controller Services configurados de Record Reader e Record Writer.
Snowflake	ConvertToJournalSchema	Converte o esquema do banco de dados recebido no esquema apropriado para uma tabela de diário CDC do Snowflake.
	CopyAzureBlobStorage_v12	Copia um blob no Armazenamento de Blobs do Azure de uma conta/contêiner para outra.
	CopyS3Object	Copia um arquivo de um bucket e a chave para outro em AWS S3
	CountText	Conta várias métricas sobre o texto recebido.
Snowflake	CreateAmazonAdsReport	Processador que cria a configuração de relatório para o conector Amazon Ads.
Snowflake	CreateAzureOpenAiEmbeddings	Usa o Azure OpenAI para criar incorporações para texto.
	CreateBoxFileMetadataInstance	Cria uma instância de metadados para um arquivo Box usando um modelo especificado com valores do conteúdo do FlowFile.
	CreateBoxMetadataTemplate	Cria um modelo de metadados Box usando especificações de campo do conteúdo do FlowFile.
Snowflake	CreateCohereEmbeddings	Usa o Cohere para criar incorporações para texto.
Snowflake	CreateMetaAdsReport	Processador que cria a configuração de relatório para o conector do Meta Ads.
Snowflake	CreateOpenAiEmbeddings	Usa o OpenAI para criar incorporações para texto.
Snowflake	CreateSnowflakeEmbeddings	Create vector embeddings using Snowflake Cortex Large Language Model functions
Snowflake	CreateVertexAIEmbeddings	Usa o VertexAI para criar incorporações para texto.
	CryptographicHashContent	Calcula um valor de hash criptográfico para o conteúdo do FlowFile usando o algoritmo fornecido e o grava em um atributo de saída.

D¶

	Processador	Descrição
	DebugFlow	O processador DebugFlow auxilia nos testes e na depuração da estrutura FlowFile, permitindo que várias respostas sejam explicitamente acionadas em resposta ao recebimento de um evento FlowFile ou de um evento de cronômetro sem um FlowFile se estiver usando cronômetro ou agendamento baseado em cron.
	DecryptContentAge	Descriptografe o conteúdo usando age-encryption.
	DecryptContentPGP	Descriptografe o conteúdo das mensagens OpenPGP.
	DeduplicateRecord	Esse processador elimina a duplicação de registros individuais em um conjunto de registros.
	DeleteAzureBlobStorage_v12	Exclui o blob especificado do Armazenamento de Blobs do Azure.
	DeleteAzureDataLakeStorage	Exclui o arquivo fornecido do Azure Data Lake Storage
	DeleteBoxFileMetadataInstance	Exclui uma instância de metadados de um arquivo Box usando a chave de modelo especificada
	DeleteByQueryElasticsearch	Exclua de um índice do Elasticsearch usando uma consulta.
Snowflake	DeleteDBFSResource	Exclua arquivos e diretórios do DBFS.
	DeleteDynamoDB	Exclui um documento DynamoDB com base no hash e na chave de intervalo.
	DeleteFile	Exclui um arquivo do sistema de arquivos.
	DeleteGCSObject	Exclui objetos de um bucket do Google Cloud.
	DeleteGridFS	Exclui um arquivo do GridFS usando um nome de arquivo ou uma consulta.
Snowflake	DeleteMilvus	Exclui vetores do banco de dados Milvus de uma coleção por ID.
	DeleteMongo	Executa uma consulta de exclusão em uma coleção MongoDB.
Snowflake	DeletePinecone	Exclui vetores de um índice Pinecone.
Snowflake	DeleteQueryJob	Exclui um trabalho de consulta no Salesforce usando a Bulk API 2.
	DeleteS3Object	Exclui um arquivo de um bucket S3 da Amazon.
	DeleteSFTP	Exclui um arquivo que reside em um servidor SFTP.
	DeleteSQS	Exclui uma mensagem de uma fila do Amazon Simple Queue Service
Snowflake	DeleteUnityCatalogResource	Excluir um arquivo ou diretório do Unity Catalog.
Snowflake	DescribeDataShare	Descreva os metadados de compartilhamento de dados especificados no Salesforce Data Cloud.
Snowflake	DescribeSFDCObject	Descreva os metadados do objeto especificado no Salesforce.
	DetectDuplicate	Armazena em cache um valor, calculado a partir dos atributos FlowFile, para cada FlowFile de entrada e determina se o valor armazenado em cache já foi visto.
	DistributeLoad	Distribui os FlowFiles para processadores downstream com base em uma estratégia de distribuição.
	DuplicateFlowFile	Destinado a testes de carga, esse processador criará o número configurado de cópias de cada FlowFile de entrada.

E¶

	Processador	Descrição
	EncodeContent	Codificar ou decodificar o conteúdo de um FlowFile usando esquemas de codificação Base64, Base32 ou hexadecimal
	EncryptContentAge	Criptografar o conteúdo usando age-encryption.
	EncryptContentPGP	Criptografe o conteúdo usando OpenPGP.
	EnforceOrder	Aplica a ordem esperada de FlowFiles que pertencem ao mesmo grupo de dados em um único nó.
Snowflake	EnrichAttributes	Procura um valor usando o serviço de pesquisa configurado e adiciona os resultados ao FlowFile como um ou mais atributos.
Snowflake	EnrichCdcStream	Enriquece FlowFiles de entrada que vêm de CaptureChangePostgreSQL etc.
	EvaluateJsonPath	Avalia uma ou mais expressões do JsonPath em relação ao conteúdo de um FlowFile.
Snowflake	EvaluateRagAnswerCorrectness	Avalia a correção das respostas geradas em um contexto de geração aumentada por recuperação (RAG), calculando métricas como pontuação F1, similaridade de cosseno e correção da resposta.
Snowflake	EvaluateRagFaithfulness	Avalia a fidelidade das respostas geradas em um sistema de geração aumentada de recuperação (RAG), analisando as respostas usando um LLM (e.
Snowflake	EvaluateRagRetrieval	Calcula métricas de recuperação (Precision@N, Recall@N, FScore@N, MAP@N, MRR) para um sistema RAG usando um LLM como juiz.
	EvaluateXPath	Avalia um ou mais XPaths em relação ao conteúdo de um FlowFile.
	EvaluateXQuery	Avalia um ou mais XQueries em relação ao conteúdo de um FlowFile.
	ExecuteGroovyScript	Processador de script Groovy estendido experimental.
	ExecuteProcess	Executa um comando do sistema operacional especificado pelo usuário e grava a saída desse comando no FlowFile.
	ExecuteScript	Experimental – Executa um script com o FlowFile e uma sessão de processo.
	ExecuteSQL	Executa a consulta SELECT SQL fornecida.
	ExecuteSQLRecord	Executa a consulta SELECT SQL fornecida.
Snowflake	ExecuteSQLStatement	Executa uma instrução SQL DDL ou DML em um banco de dados.
	ExecuteStreamCommand	O processador ExecuteStreamCommand oferece uma maneira flexível de integrar comandos e scripts externos aos fluxos de dados do NiFi.
	ExtractAvroMetadata	Extrai metadados do cabeçalho de um arquivo de dados Avro.
	ExtractEmailAttachments	Extraia os anexos de um arquivo de e-mail com formato mime, dividindo-os em FlowFiles individuais.
	ExtractEmailHeaders	Usando o conteúdo do FlowFile como fonte de dados, extraia o cabeçalho de um arquivo de e-mail compatível com a RFC adicionando os atributos relevantes ao FlowFile.
	ExtractGrok	Avalia uma ou mais expressões Grok em relação ao conteúdo de um FlowFile, adicionando os resultados como atributos ou substituindo o conteúdo do FlowFile por uma notação JSON do conteúdo correspondente
	ExtractRecordSchema	Extrai o esquema de registro do FlowFile usando o Record Reader fornecido e o grava no avro.
Snowflake	ExtractSchemaColumns	Extrai as colunas do esquema de registro do FlowFile usando o Record Reader fornecido e as grava no esquema.
	ExtractStructuredBoxFileMetadata	Extrai metadados de um arquivo Box usando a Box AI.
	ExtractText	Avalia uma ou mais expressões regulares em relação ao conteúdo de um FlowFile.

F¶

	Processador	Descrição
	FetchAzureBlobStorage_v12	Recupera o blob especificado do Armazenamento de Blobs do Azure e grava seu conteúdo no conteúdo do FlowFile.
	FetchAzureDataLakeStorage	Busque o arquivo especificado no Azure Data Lake Storage
	FetchBoxFile	Obtenha os arquivos de uma pasta Box.
	FetchBoxFileInfo	Obtém metadados de arquivos Box e os adiciona aos atributos do FlowFile.
	FetchBoxFileMetadataInstance	Recupera a instância de metadados específica associada a um arquivo Box usando a chave e o escopo do modelo.
	FetchBoxFileRepresentation	Obtém uma representação de arquivo Box usando uma dica de representação e a grava no conteúdo do FlowFile.
	FetchDistributedMapCache	Calcula a(s) chave(s) do cache a partir dos atributos do FlowFile, para cada FlowFile de entrada, e busca o(s) valor(es) do cache de mapa distribuído associado a cada chave.
	FetchDropbox	Busca arquivos do Dropbox.
	FetchFile	Lê o conteúdo de um arquivo do disco e o transmite ao conteúdo de um FlowFile de entrada.
	FetchFTP	Obtém o conteúdo de um arquivo de um servidor FTP remoto e substitui o conteúdo de um FlowFile de entrada pelo conteúdo do arquivo remoto.
	FetchGCSObject	Obtém um arquivo de um bucket Google Cloud.
	FetchGoogleDrive	Obtém arquivos de uma pasta do Google Drive.
Snowflake	FetchGoogleDriveFileComments	Obtém comentários e suas respostas para um arquivo do Google Drive.
Snowflake	FetchGoogleDriveMetadata	Obtém metadados de arquivos do Google Drive.
	FetchGridFS	Recupera um ou mais arquivos de um bucket GridFS por nome de arquivo ou por uma consulta definida pelo usuário.
Snowflake	FetchJiraIssues	Obtém problemas do Jira Cloud usando a REST API v3 com opções de pesquisa configuráveis.
Snowflake	FetchMicrosoftDataverseTable	Obtenha registros de tabelas do Microsoft Dataverse
	FetchS3Object	Recupera o conteúdo de um objeto S3 e o grava no conteúdo de um objeto FlowFile
	FetchSFTP	Obtém o conteúdo de um arquivo de um servidor SFTP remoto e substitui o conteúdo de um FlowFile de entrada pelo conteúdo do arquivo remoto.
Snowflake	FetchSharepointFile	Busca o conteúdo de um arquivo de uma unidade Sharepoint, opcionalmente baixando uma versão PDF ou HTML do arquivo, quando aplicável.
Snowflake	FetchSharepointMetadata	Para cada unidade, o item recupera seus metadados e permissões e os grava como atributos do FlowFile.
Snowflake	FetchSlackConversationInfo	Obtém informações de conversas do Slack e e-mails de membros
Snowflake	FetchSlackFile	Faz o download de um arquivo compartilhado no Slack.
Snowflake	FetchSlackMessage	Obtém dados sobre uma única mensagem do Slack
	FetchSmb	Obtém arquivos de um compartilhamento SMB.
Snowflake	FetchSnowflakeTableProperties	Lê as propriedades de uma tabela e as armazena como atributos do FlowFile.
Snowflake	FetchSourceTableSchema	Obtém o esquema da tabela (i.
Snowflake	FetchTableSnapshot	Obtém um instantâneo de uma tabela de um banco de dados.
	FilterAttribute	Filtra os atributos de um FlowFile mantendo os atributos especificados e removendo o restante ou removendo os atributos especificados e mantendo o restante.
Snowflake	FindSharepointDriveItem	Localiza um item do drive do Sharepoint pelo ID do drive e pelo caminho do item.
	FlattenJson	Oferece ao usuário a capacidade de pegar um documento JSON aninhado e nivelá-lo em um documento simples de par chave-valor.
	ForkEnrichment	Usado em conjunto com o processador JoinEnrichment, esse processador é responsável por adicionar os atributos necessários para que o processador JoinEnrichment execute sua função.
	ForkRecord	Esse processador permite que o usuário bifurque um registro em vários registros.

G¶

	Processador	Descrição
Snowflake	GenerateAnswersFromContext	Gera respostas sintéticas para cada pergunta presente nos registros de entrada usando um modelo de linguagem grande (LLM).
Snowflake	GenerateAnswersFromGroundTruth	Gera respostas sintéticas para cada pergunta nos registros de entrada usando um LLM.
	GenerateFlowFile	Esse processador cria os FlowFiles com dados aleatórios ou conteúdo personalizado.
Snowflake	GenerateJSON	Produz um lote de objetos JSON com valores de campo aleatórios com base em um esquema JSON configurável.
	GenerateRecord	Esse processador cria os FlowFiles com registros com valores aleatórios para os campos especificados.
	GenerateTableFetch	Gera consultas de seleção SQL que buscam “páginas” de linhas de uma tabela.
	GeoEnrichIP	Procura informações de geolocalização para um endereço IP e adiciona as informações geográficas aos atributos do FlowFile.
	GeoEnrichIPRecord	Procura informações de geolocalização para um endereço IP e adiciona as informações geográficas aos atributos do FlowFile.
Snowflake	GetAmazonAdsReport	O processador está baixando o relatório do Amazon Ads, se estiver pronto.
	GetAwsPollyJobStatus	Recupera o status atual de um trabalho do AWS Polly.
	GetAwsTextractJobStatus	Recupera o status atual de um trabalho do AWS Textract.
	GetAwsTranscribeJobStatus	Recupera o status atual de um trabalho do AWS Transcribe.
	GetAwsTranslateJobStatus	Recupera o status atual de um trabalho do AWS Translate.
	GetAzureEventHub	Recebe mensagens dos Hubs de Eventos do Microsoft Azure sem rastreamento confiável de pontos de verificação.
	GetAzureQueueStorage_v12	Recupera as mensagens de um Armazenamento de Filas do Azure.
	GetBoxFileCollaborators	Recupera todos os colaboradores em um arquivo Box e adiciona as informações de colaboração aos atributos do FlowFile.
	GetBoxGroupMembers	Recupera membros de um grupo Box e grava seus detalhes nos atributos do FlowFile.
Snowflake	GetDataShareCredentials	Descreva os metadados de compartilhamento de dados especificados no Salesforce Data Cloud.
Snowflake	GetDataShareTables	Descreva os metadados de compartilhamento de dados especificados no Salesforce Data Cloud.
Snowflake	GetDBFSFile	Leia um arquivo DBFS.
	GetDynamoDB	Recupera um documento do DynamoDB com base no hash e na chave de intervalo.
	GetElasticsearch	Processador de obtenção do Elasticsearch que usa as bibliotecas de cliente oficiais do Elastic REST para buscar um único documento do Elasticsearch por _id.
	GetFile	Cria o FlowFiles a partir de arquivos em um diretório.
	GetFileResource	Esse processador cria os FlowFiles com o conteúdo do recurso de arquivo configurado.
	GetFTP	Obtém arquivos de um servidor FTP e cria FlowFiles a partir deles
	GetGcpVisionAnnotateFilesOperationStatus	Recupera o status atual de uma operação do Google Vision.
	GetGcpVisionAnnotateImagesOperationStatus	Recupera o status atual de uma operação do Google Vision.
Snowflake	GetGoogleAdsReport	Um processador que pode interagir com a Google Ads Reporting API.
Snowflake	GetGoogleGroupMembers	Recupera os membros de um ou mais grupos do Google, especificados como uma lista de IDs de grupo separados por vírgulas que é fornecida como um atributo FlowFile.
Snowflake	GetGoogleSheets	Processador responsável pela obtenção de dados das Planilhas Google.
	GetHubSpot	Recupera os dados JSON de um aplicativo HubSpot privado.
Snowflake	GetHubSpotObject	Obtenha um objeto HubSpot e suas associações por ID ou valor exclusivo.
Snowflake	GetLinkedInAdsReport	Processador baixando métricas das LinkedIn Reporting APIs.
Snowflake	GetMicrosoft365GroupMembers	Recupera os membros do grupo Microsoft365 e emite um FlowFile para cada alteração ocorrida.
	GetMongo	Cria FlowFiles a partir de documentos em MongoDB carregados por uma consulta especificada pelo usuário.
	GetMongoRecord	Uma versão baseada em registros do GetMongo que usa os Record Writers para gravar o conjunto de resultados do MongoDB.
Snowflake	GetQueryJobResult	Obtém os resultados de um trabalho de consulta no Salesforce usando a Bulk API 2.
Snowflake	GetQueryJobStatus	Obtém o status de um trabalho de consulta no Salesforce usando a Bulk API 2.
	GetS3ObjectMetadata	Verifique a existência de um objeto no S3 e busque seus metadados sem tentar baixá-lo.
	GetS3ObjectTags	Verifique a existência de um objeto no S3 e busque suas tags sem tentar baixá-lo.
	GetSFTP	Obtém arquivos de um servidor SFTP e cria FlowFiles a partir deles
Snowflake	GetSharepointSiteGroupMembers	Recupera todos os membros de um grupo do site SharePoint.
	GetShopify	Recupera objetos de uma loja Shopify personalizada.
	GetSmbFile	Lê o arquivo de um local de rede samba para FlowFiles.
	GetSplunk	Recupera dados do Splunk Enterprise.
	GetSQS	Obtém mensagens de uma fila do Amazon Simple Queue Service
Snowflake	GetUnityCatalogFile	Leia um arquivo do Unity Catalog de até 5 GiB.
Snowflake	GetUnityCatalogFileMetadata	Verifica os metadados do arquivo do Unity Catalog.
	GetWorkdayReport	Um processador que pode interagir com um relatório configurável do Workday.
	GetZendesk	Obtém dados de forma incremental da API Zendesk.

H¶

	Processador	Descrição
	HandleHttpRequest	Inicia um servidor HTTP e escuta as solicitações HTTP.
	HandleHttpResponse	Envia uma resposta HTTP para o solicitante que gerou um FlowFile.

I¶

	Processador	Descrição
	IdentifyMimeType	Tenta identificar o tipo MIME usado para um FlowFile.
	InvokeHTTP	Um processador cliente HTTP que pode interagir com um ponto de extremidade HTTP configurável.
	InvokeScriptedProcessor	Experimental – Invoca um mecanismo de script para um processador definido no script fornecido.
	ISPEnrichIP	Procura informações no ISP para um endereço IP e adiciona as informações aos atributos FlowFile.

J¶

	Processador	Descrição
	JoinEnrichment	Une registros de dois FlowFiles diferentes, sendo que um FlowFile, o “original”, contém registros arbitrários e o segundo FlowFile, o “enrichment”, contém dados adicionais que devem ser usados para enriquecer o primeiro.
	JoltTransformJSON	Aplica uma lista de especificações JOLT ao conteúdo JSON do FlowFile ou a um atributo JSON do FlowFile especificado.
	JoltTransformRecord	Aplica uma especificação JOLT a cada registro no payload do FlowFile.
	JSLTTransformJSON	Aplica uma transformação JSLT à carga útil JSON do FlowFile.
	JsonQueryElasticsearch	Um processador que permite ao usuário executar uma consulta (com agregações) escrita com o Elasticsearch JSON DSL.

L¶

	Processador	Descrição
Snowflake	ListArchivedHubSpotData	Lista os dados arquivados do HubSpot para o tipo de objeto escolhido e gera um FlowFile por objeto listado com os metadados correspondentes como atributos do FlowFile.
	ListAzureBlobStorage_v12	Lista os blobs em um contêiner do Armazenamento de Blobs do Azure.
	ListAzureDataLakeStorage	Lista o diretório em um sistema de arquivos do Azure Data Lake Storage Gen2
	ListBoxFile	Lista os arquivos em uma pasta Box.
	ListBoxFileInfo	Obtém metadados de arquivo para cada arquivo em uma pasta Box.
	ListBoxFileMetadataInstances	Recupera todas as instâncias de metadados associadas a um arquivo Box.
	ListBoxFileMetadataTemplates	Recupera todos os modelos de metadados associados a um arquivo Box.
	ListDatabaseTables	Gera um conjunto de FlowFiles, cada um contendo atributos correspondentes a metadados sobre uma tabela de uma conexão de banco de dados.
Snowflake	ListDBFSDirectory	Lista os nomes de arquivos em um diretório DBFS e gera um novo FlowFile com o nome do arquivo.
	ListDropbox	Recupera uma listagem de arquivos do Dropbox (os atalhos são ignorados).
	ListenFTP	Inicia um servidor FTP que escuta na porta especificada e transforma os arquivos recebidos em FlowFiles.
	ListenHTTP	Inicia um servidor HTTP e escuta em um determinado caminho base para transformar as solicitações recebidas em FlowFiles.
	ListenOTLP	Colete as mensagens OpenTelemetry em HTTP ou gRPC.
	ListenSlack	Recupera mensagens em tempo real ou comandos do Slack de uma ou mais conversas do Slack.
	ListenSyslog	Você escuta as mensagens do Syslog que estão sendo enviadas para uma determinada porta TCP ou UDP.
	ListenTCP	Ouve as conexões TCP de entrada e lê os dados de cada conexão usando um separador de linha como demarcador de mensagem.
	ListenUDP	Escuta os pacotes de datagrama em uma determinada porta.
	ListenUDPRecord	Escuta os pacotes de datagrama em uma determinada porta e lê o conteúdo de cada datagrama usando o Record Reader configurado.
	ListenWebSocket	Atua como um ponto de extremidade do servidor WebSocket para aceitar conexões de clientes.
	ListFile	Recupera uma listagem de arquivos do diretório de entrada.
	ListFTP	Executa uma listagem dos arquivos que residem em um servidor FTP.
	ListGCSBucket	Recupera uma listagem de objetos de um bucket GCS.
	ListGoogleDrive	Executa uma listagem de arquivos concretos (os atalhos são ignorados) em uma pasta do Google Drive.
Snowflake	ListGoogleDriveFileInfo	Lista todos os arquivos e pastas em um Google Drive específico.
Snowflake	ListGoogleGroups	Lista todos os grupos de um determinado domínio no Google Workspace.
Snowflake	ListHubSpotObjects	Obtém dados de HubSpot para tipos de objetos especificados e gera um FlowFile por objeto listado com os metadados correspondentes como atributos do FlowFile.
Snowflake	ListMicrosoftDataverseTables	Tabelas de lista de ambientes do Microsoft Dataverse
	ListS3	Recupera uma listagem de objetos de um bucket S3.
Snowflake	ListSFDCDataShares	Liste os compartilhamentos de dados disponíveis na organização que estão disponíveis para o usuário identificado.
Snowflake	ListSFDCObjects	Liste os objetos disponíveis na organização que estão disponíveis para o usuário identificado.
	ListSFTP	Executa uma listagem dos arquivos que residem em um servidor SFTP.
Snowflake	ListSharepointDrives	Emite um FlowFile para cada unidade presente no site Sharepoint especificado.
Snowflake	ListSharepointSiteGroups	Lista todos os grupos de sites SharePoint disponíveis em um site SharePoint especificado.
	ListSmb	Lista arquivos concretos compartilhados por meio do protocolo SMB.
Snowflake	ListTableNames	Busca todos os nomes de tabela de origem e os associa a uma das configurações possíveis:- expressão regexp e.
Snowflake	ListUnityCatalogDirectory	Lista os nomes de arquivos em um diretório do Unity Catalog e gera um novo FlowFile com o nome de arquivo.
	LogAttribute	Emite atributos do FlowFile no nível de registro especificado
	LogMessage	Emite uma mensagem de registro no nível de registro especificado
	LookupAttribute	Atributos de pesquisa de um serviço de pesquisa
	LookupRecord	Extrai um ou mais campos de um registro e procura um valor para esses campos em LookupService.

M¶

	Processador	Descrição
	MergeContent	Mescla um grupo de FlowFiles com base em uma estratégia definida pelo usuário e os empacota em um único FlowFile.
	MergeRecord	Esse processador mescla vários registros orientados para FlowFiles em um único FlowFile que contém todos os registros dos FlowFiles de entrada.
Snowflake	MergeSnowflakeJournalTable	Aciona uma operação de fusão nas alterações da tabela de diário para uma tabela de destino no Snowflake.
	ModifyBytes	Descarta o intervalo de bytes no início e no fim ou todo o conteúdo de um arquivo binário.
	ModifyCompression	Altera o algoritmo de compressão usado para compactar o conteúdo de um FlowFile, descompactando o conteúdo do FlowFiles usando um algoritmo de compressão especificado pelo usuário e recomprimindo o conteúdo usando as propriedades de formato de compressão especificadas.
	MonitorActivity	Monitora a atividade do fluxo e envia um indicador quando o fluxo não tem dados por um período de tempo especificado e novamente quando a atividade do fluxo é restaurada
	MoveAzureDataLakeStorage	Move o conteúdo em um Azure Data Lake Storage Gen2.

N¶

	Processador	Descrição
	Notificar	Armazena em cache um identificador de sinal de liberação no cache distribuído, opcionalmente junto com os atributos do FlowFile.

O¶

	Processador	Descrição
Snowflake	OpenAiTranscribeAudio	Transcreve o áudio para o texto em inglês.

P¶

	Processador	Descrição
	PackageFlowFile	Esse processador empacotará os atributos e o conteúdo do FlowFile em um FlowFile de saída que pode ser exportado do NiFi e importado de volta para ao NiFi, preservando os atributos e o conteúdo originais.
	PaginatedJsonQueryElasticsearch	Um processador que permite ao usuário executar uma consulta paginada (com agregações) escrita com o Elasticsearch JSON DSL.
	ParseEvtx	Analisa o conteúdo de um arquivo de registro de eventos do Windows (EVTX) e grava o resultado em XML no arquivo FlowFile
Snowflake	ParseExcelCellReference	Processador responsável pela análise da fórmula de referência da célula do Excel.
	ParseSyslog	Tenta analisar o conteúdo de uma mensagem do Syslog de acordo com os formatos da RFC5424 e RFC3164 e adiciona atributos ao FlowFile para cada uma das partes da mensagem do Syslog.
	ParseSyslog5424	Tenta analisar o conteúdo de uma mensagem do Syslog bem formada de acordo com o formato da RFC5424 e adiciona atributos ao FlowFile para cada uma das partes da mensagem do Syslog, incluindo dados estruturados.
	PartitionRecord	Divide, ou particiona, dados orientados a registros com base nos campos configurados nos dados.
Snowflake	PerformSnowflakeCortexOCR	Realiza o reconhecimento óptico de caracteres (OCR) em documentos PDF usando as funções do Snowflake Cortex ML.
Snowflake	PickTablesForReplication	Aceita uma lista de nomes de tabelas totalmente qualificados e determina se uma tabela: é nova (não é replicada, mas foi adicionada na fonte); é existente (é replicada e existe na fonte); ou é obsoleta (é replicada, mas não existe mais na fonte). A configuração é passada como um atributo do FlowFile.
Snowflake	PromptAnthropicAI	Envia um prompt ao Anthropic, escrevendo a resposta como um atributo do FlowFile ou no conteúdo do FlowFile de entrada.
Snowflake	PromptAzureOpenAI	Envia um prompt para o serviço OpenAI do Azure, gravando a resposta como um atributo FlowFile ou no conteúdo do FlowFile de entrada.
Snowflake	PromptLLM	Esse processador envia um prompt definido pelo usuário para um modelo de linguagem grande (LLM) para responder.
Snowflake	PromptOpenAI	Envia um prompt ao OpenAI, gravando a resposta como um atributo do FlowFile ou no conteúdo do FlowFile de entrada.
Snowflake	PromptSnowflakeCortex	Envia um prompt ao Snowflake Cortex, escrevendo a resposta como um atributo do FlowFile ou para o conteúdo do FlowFile de entrada.
Snowflake	PromptVertexAI	Envia um prompt ao VertexAI, gravando a resposta como um atributo do FlowFile ou no conteúdo do FlowFile de entrada.
	PublishAMQP	Cria uma mensagem AMQP a partir do conteúdo de um FlowFile e envia a mensagem para um AMQP Exchange.
	PublishGCPubSub	Publica o conteúdo do FlowFile de entrada no tópico configurado do Google Cloud PubSub.
	PublishJMS	Cria uma mensagem JMS a partir do conteúdo de um FlowFile e a envia para um destino JMS (fila ou tópico) como JMS BytesMessage ou TextMessage.
	PublishKafka	Envia o conteúdo de um FlowFile como uma mensagem ou como registros individuais ao Apache Kafka usando a Kafka Producer API.
Snowflake	PublishKafka	Envia o conteúdo de um FlowFile como uma mensagem ou como registros individuais ao Apache Kafka usando a Kafka Producer API.
	PublishMQTT	Publica uma mensagem em um tópico MQTT
	PublishSlack	Publica uma mensagem no canal do Slack especificado.
	PutAzureBlobStorage_v12	Coloca o conteúdo em um Armazenamento de Blobs do Azure.
	PutAzureCosmosDBRecord	Esse processador é um processador com reconhecimento de registros para inserir dados no Cosmos DB com a Core SQL API.
	PutAzureDataExplorer	Atua como um coletor do Azure Data Explorer que envia FlowFiles ao ponto de extremidade fornecido.
	PutAzureDataLakeStorage	Grava o conteúdo de um FlowFile como um arquivo no Azure Data Lake Storage Gen2
	PutAzureEventHub	Envie o conteúdo do FlowFile aos Hubs de Eventos do Azure
	PutAzureQueueStorage_v12	Grava o conteúdo dos FlowFiles de entrada no Armazenamento de Filas do Azure configurado.
	PutBigQuery	Grava o conteúdo de um FlowFile em uma tabela do Google BigQuery.
	PutBoxFile	Coloca o conteúdo em uma pasta Box.
	PutCloudWatchMetric	Publica métricas no Amazon CloudWatch.
	PutDatabaseRecord	O processador PutDatabaseRecord usa um RecordReader especificado para inserir (possivelmente vários) registros de um FlowFile de entrada.
Snowflake	PutDatabricksSQL	Envie uma execução SQL usando a Databricks REST API e, em seguida, escreva a resposta JSON no conteúdo de FlowFile.
Snowflake	PutDBFSFile	Escreva o conteúdo de FlowFile para DBFS.
	PutDistributedMapCache	Obtém o conteúdo de um FlowFile e o coloca em um cache de mapa distribuído, usando uma chave de cache calculada a partir dos atributos do FlowFile.
	PutDropbox	Coloca o conteúdo em uma pasta do Dropbox.
	PutDynamoDB	Coloca um documento do DynamoDB com base no hash e na chave de intervalo.
	PutDynamoDBRecord	Insere itens no DynamoDB com base em dados orientados por registros.
	PutElasticsearchJson	Um processador Elasticsearch PUT que usa as bibliotecas de cliente Elastic REST oficiais.
	PutElasticsearchRecord	Um processador Elasticsearch PUT com reconhecimento de registros que usa as bibliotecas de cliente Elastic REST oficiais.
	PutEmail	Envia um e-mail aos destinatários configurados para cada FlowFile de entrada
	PutFile	Grava o conteúdo de um FlowFile no sistema de arquivos local
	PutFTP	Envia FlowFiles para um servidor FTP
	PutGCSObject	Grava o conteúdo de um FlowFile como um objeto no Google Cloud Storage.
	PutGoogleDrive	Grava o conteúdo de um FlowFile como um arquivo no Google Drive.
	PutGridFS	Grava um arquivo em um bucket GridFS.
Snowflake	PutHubSpot	Insira um objeto HubSpot.
Snowflake	PutIcebergTable	Armazene registros no Iceberg usando o Catalog configurável para gerenciar namespaces e tabelas.
	PutKinesisFirehose	Envia o conteúdo para um Amazon Kinesis Firehose especificado.
	PutKinesisStream	Envia o conteúdo para um Amazon Kinesis especificado.
	PutLambda	Envia o conteúdo para uma função Amazon Lambda especificada.
	PutMongo	Grava o conteúdo de um FlowFile no MongoDB
	PutMongoBulkOperations	Grava o conteúdo de um FlowFile no MongoDB como uma atualização em lote
	PutMongoRecord	Esse é um processador com reconhecimento de registros para inserir/executar upsert de dados no MongoDB.
	PutRecord	O processador PutRecord usa um RecordReader especificado para inserir (possivelmente vários) registros de um FlowFile de entrada e os envia a um destino especificado por um serviço de destino de registro (i.
	PutRedisHashRecord	Coloca os dados do campo de registro no Redis usando um valor de hash especificado, que é determinado por um RecordPath para um campo em cada registro que contém o valor de hash.
	PutS3Object	Grava o conteúdo de um FlowFile como um objeto S3 em um bucket S3 da Amazon.
	PutSalesforceObject	Cria novos registros para o sObject do Salesforce especificado.
	PutSFTP	Envia FlowFiles para um servidor SFTP
	PutSmbFile	Grava o conteúdo de um FlowFile em um local de rede Samba.
Snowflake	PutSnowflakeInternalStageFile	Coloca os arquivos em um estágio interno do Snowflake.
Snowflake	PutSnowpipeStreaming	Transfere registros para uma tabela Snowflake.
	PutSNS	Envia o conteúdo de um FlowFile como uma notificação para o Amazon Simple Notification Service
	PutSplunk	Envia registros ao Splunk Enterprise por meio de TCP, TCP + TLS/SSL ou UDP.
	PutSplunkHTTP	Envia o conteúdo do FlowFile ao servidor Splunk especificado por meio de HTTP ou HTTPS.
	PutSQL	Executa um comando SQL UPDATE ou INSERT.
	PutSQS	Publica uma mensagem em uma fila do Amazon Simple Queue Service
	PutSyslog	Envia mensagens do Syslog para um determinado host e porta por meio de TCP ou UDP.
	PutTCP	Envia FlowFiles ou registros serializados via TCP para um destino configurável com suporte opcional para TLS
	PutUDP	O processador PutUDP recebe um FlowFile e empacota o conteúdo do FlowFile em um único pacote de datagrama UDP, que é então transmitido ao servidor UDP configurado.
Snowflake	PutUnityCatalogFile	Escreva o conteúdo do FlowFile com tamanho máximo de 5 GiB para o Unity Catalog.
Snowflake	PutVectaraDocument	Gere e carregue um documento JSON aos pontos de extremidade de upload do Vectara.
Snowflake	PutVectaraFile	Faça o upload de um conteúdo do FlowFile para os pontos de extremidade de índice do Vectara.
	PutWebSocket	Envia mensagens para um ponto de extremidade remoto WebSocket usando uma sessão WebSocket estabelecida por ListenWebSocket ou ConnectWebSocket.
	PutZendeskTicket	Crie tíquetes Zendesk usando a Zendesk API.

Q¶

	Processador	Descrição
	QueryAzureDataExplorer	Consulte o Azure Data Explorer e transmita os resultados do JSON aos FlowFiles de saída
	QueryDatabaseTable	Gera uma consulta SQL SELECT, ou usa uma instrução fornecida, e a executa para buscar todas as linhas cujos valores na(s) coluna(s) especificada(s) como Valor máximo (Maximum Value) sejam maiores que os máximos registrados anteriormente.
	QueryDatabaseTableRecord	Gera uma consulta SQL SELECT, ou usa uma instrução fornecida, e a executa para buscar todas as linhas cujos valores na(s) coluna(s) especificada(s) como Valor máximo (Maximum Value) sejam maiores que os máximos registrados anteriormente.
Snowflake	QueryMilvus	Consulta uma determinada coleção em um banco de dados Milvus usando vetores.
Snowflake	QueryPinecone	Consulta o Pinecone em busca de vetores que sejam semelhantes ao vetor de entrada ou recupera um vetor por meio de ID.
	QueryRecord	Avalia uma ou mais consultas SQL em relação ao conteúdo de um FlowFile.
	QuerySalesforceObject	Recupera registros de um sObject do Salesforce.
	QuerySplunkIndexingStatus	Consulta o servidor Splunk para obter o status da confirmação de indexação.

R¶

	Processador	Descrição
	RemoveRecordField	Modifica o conteúdo de um FlowFile que contém dados orientados por registros (i.
	RenameRecordField	Renomeia um ou mais campos em cada registro de um FlowFile.
	ReplaceText	Atualiza o conteúdo de um FlowFile pesquisando algum valor textual no conteúdo do FlowFile (por meio de expressão regular/regex ou valor literal) e substituindo a seção do conteúdo correspondente por algum valor alternativo.
	ReplaceTextWithMapping	Atualiza o conteúdo de um FlowFile avaliando uma expressão regular em relação a ele e substituindo a seção do conteúdo que corresponde à expressão regular por algum valor alternativo fornecido em um arquivo de mapeamento.
	RetryFlowFile	FlowFiles passados para esse processador têm um valor de “Atributo de nova tentativa” verificado em relação a um valor configurado de “Máximo de novas tentativas”.
	RouteOnAttribute	Roteia FlowFiles com base em seus atributos usando a linguagem de expressão de atributos
	RouteOnContent	Aplica expressões regulares ao conteúdo de um FlowFile e encaminha uma cópia do FlowFile para cada destino cuja expressão regular corresponda.
	RouteText	Encaminha dados textuais com base em um conjunto de regras definidas pelo usuário.
Snowflake	RunDatabricksJob	Aciona um trabalho pré-definido do Databricks para ser executado com parâmetros personalizados.
	RunMongoAggregation	Um processador que executa uma consulta de agregação sempre que um FlowFile é recebido.

S¶

	Processador	Descrição
	SampleRecord	Amostra os registros de um FlowFile com base em uma estratégia de amostragem especificada (como a Amostra de reservatório (Reservoir Sampling)).
	ScanAttribute	Examina os atributos especificados dos FlowFiles, verificando se algum de seus valores está presente no dicionário de termos especificado
	ScanContent	Examina o conteúdo dos FlowFiles em busca de termos encontrados em um dicionário fornecido pelo usuário.
	ScriptedFilterRecord	Esse processador oferece a capacidade de filtrar registros dos FlowFiles usando o script fornecido pelo usuário.
	ScriptedPartitionRecord	Recebe dados orientados por registros (i.
	ScriptedTransformRecord	Oferece a capacidade de avaliar um script simples em relação a cada registro em um FlowFile de entrada.
	ScriptedValidateRecord	Esse processador oferece a capacidade de validar registros nos FlowFiles usando o script fornecido pelo usuário.
	SearchElasticsearch	Um processador que permite ao usuário executar repetidamente uma consulta paginada (com agregações) escrita com o Elasticsearch JSON DSL.
	SegmentContent	Segmenta o FlowFile em vários segmentos menores com base nos limites de bytes.
	SignContentPGP	Assine o conteúdo usando as chaves privadas OpenPGP
Snowflake	SnowflakeDetectDuplicate	Verifica se o hash de um FlowFile (fornecido como atributo do FlowFile) já está em uma tabela Snowflake e encaminha o FlowFile para “duplicate” se encontrado, “distinct” se não encontrado ou “failure” em caso de erro.
	SplitAvro	Divide um arquivo de dados Avro codificado em binário em arquivos menores com base no tamanho de saída configurado.
	SplitContent	Divide os FlowFiles de entrada por uma sequência de bytes especificada
	SplitExcel	Esse processador divide uma planilha do Microsoft Excel com várias planilhas em várias planilhas do Microsoft Excel, sendo que cada planilha do arquivo original é convertida em uma planilha individual em seu próprio FlowFile.
	SplitJson	Divide um arquivo JSON em vários FlowFiles separados para um elemento de matriz especificado por uma expressão JsonPath.
	SplitRecord	Divide um FlowFile de entrada que está em um formato de dados orientado a registros em vários FlowFiles menores
	SplitText	Divide um arquivo de texto em vários arquivos de texto menores em limites de linha limitados pelo número máximo de linhas ou pelo tamanho total do fragmento.
	SplitXml	Divide um arquivo XML em vários FlowFiles separados, cada um compreendendo um filho ou descendente do elemento raiz original
	StartAwsPollyJob	Acione um trabalho do AWS Polly.
	StartAwsTextractJob	Acione um trabalho do AWS Textract.
	StartAwsTranscribeJob	Acione um trabalho do AWS Trancribe.
	StartAwsTranslateJob	Acione um trabalho do AWS Translate.
	StartGcpVisionAnnotateFilesOperation	Acione uma operação do Vision na entrada do arquivo.
	StartGcpVisionAnnotateImagesOperation	Acione uma operação do Vision na entrada de imagem.
Snowflake	SubmitQueryJob	Envia um trabalho de consulta ao Salesforce usando a Bulk API 2.
Snowflake	SummarizeText	Esse processador usa um modelo de linguagem grande (LLM) para resumir o conteúdo de um FlowFile.

T¶

	Processador	Descrição
	TagS3Object	Adiciona ou atualiza uma tag em um objeto do Amazon S3.
	TailFile	Monitora com o comando tail um arquivo, ou uma lista de arquivos, ingerindo dados do arquivo à medida que são gravados no arquivo.
	TransformXml	Aplica o arquivo XSLT fornecido à carga XML do FlowFile.

U¶

	Processador	Descrição
	UnpackContent	Descompacta o conteúdo dos FlowFiles que foi empacotado com um dos vários formatos de empacotamento diferentes, emitindo de um a vários FlowFiles para cada FlowFile de entrada.
	UpdateAttribute	Atualiza os atributos de um FlowFile usando a linguagem de expressão de atributo e/ou exclui os atributos com base em uma expressão regular
	UpdateBoxFileMetadataInstance	Atualiza os valores do modelo de metadados de um arquivo Box usando o registro no FlowFile fornecido.
	UpdateByQueryElasticsearch	Atualize documentos em um índice do Elasticsearch usando uma consulta.
	UpdateCounter	Esse processador permite que os usuários definam contadores específicos e pontos-chave em seu fluxo.
	UpdateDatabaseTable	Esse processador usa uma conexão JDBC e registros de entrada para gerar quaisquer alterações na tabela do banco de dados necessárias para oferecer suporte aos registros de entrada.
	UpdateRecord	Atualiza o conteúdo de um FlowFile que contém dados orientados por registros (i.
Snowflake	UpdateSnowflakeDatabase	Atualiza a definição de uma tabela Snowflake com base no esquema fornecido no FlowFile de entrada.
Snowflake	UpdateSnowflakeIcebergDatabase	Atualiza a definição de uma tabela Snowflake Iceberg.
Snowflake	UpdateTableState	Atualiza o estado de uma tabela no serviço de estado da tabela
Snowflake	UpsertMilvus	Insere vetores no banco de dados do Milvus para uma determinada coleção
Snowflake	UpsertPinecone	Publica vetores, incluindo metadados e, opcionalmente, texto, em um índice Pinecone.
Snowflake	UpsertSFDCObjects	Insere os registros do FlowFile de entrada no Salesforce

V¶

	Processador	Descrição
	ValidateCsv	Valida o conteúdo dos FlowFiles ou um valor de atributo do FlowFile em relação a um esquema CSV especificado pelo usuário.
	ValidateJson	Valida o conteúdo dos FlowFiles em relação a um esquema JSON configurável.
	ValidateRecord	Valida os registros de um FlowFile de entrada em relação a um determinado esquema.
	ValidateXml	Valida XML contido em um FlowFile.
	VerifyContentMAC	Calcula um código de autenticação de mensagem usando a chave secreta fornecida e o compara com a propriedade MAC fornecida
	VerifyContentPGP	Verifica assinaturas usando as chaves públicas do OpenPGP

W¶

	Processador	Descrição
	Wait	Encaminha os FlowFiles de entrada para a relação “wait” até que um sinal de liberação correspondente seja armazenado no cache distribuído de um processador Notify correspondente.
Snowflake	WaitForTableState	Bloqueia os FlowFiles de entrada até que o estado da tabela correspondente não seja igual ao estado aceito.