Tous les processeurs (par ordre alphabétique)¶

Cette rubrique fournit une liste de tous les processeurs Snowflake par ordre alphabétique. La liste comprend :

Le nom de chaque processeur

Un résumé de chaque processeur

A¶

	Processeur	Description
	AbortQueryJob	Abandonne une requête dans Salesforce à l’aide de la fonction Bulk API 2.
	AttributesToCSV	Génère une représentation CSV des attributs du FlowFile d’entrée.
	AttributesToJSON	Génère une représentation JSON des attributs du FlowFile d’entrée.

C¶

	Processeur	Description
	CalculateRecordStats	Compte le nombre d’enregistrements compris dans un ensemble d’enregistrements en dénombrant éventuellement les éléments par catégorie - les catégories étant définies par des propriétés définies par l’utilisateur.
	CaptureChangeMySQL	Lit les événements CDC à partir d’une base de données MySQL.
	CaptureChangePostgreSQL	Lit les événements CDC à partir d’une base de données PostgreSQL.
	CaptureChangeSqlServer	Lit les événements CDC à partir d’une base de données SQL Server.
	CaptureGoogleDriveChanges	Capture les modifications apportées à un Google Drive partagé et émet un FlowFile pour chaque modification survenue.
	CaptureMicrosoft365GroupsChanges	Capture les changements survenant dans les groupes Microsoft365 et émet un FlowFile pour chaque changement qui se produit.
	CaptureSharepointChanges	Capture les changements survenus dans une bibliothèque de documents Sharepoint et émet un FlowFile pour chacun d’entre eux.
	CheckMetaAdsReportReadiness	Ce processeur vérifie si le rapport Meta Ads est prêt à être téléchargé.
	ChunkRecordText	Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères.
	ChunkText	Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères.
	CompressContent	Compresse ou décompresse le contenu de FlowFiles à l’aide d’un algorithme de compression spécifié par l’utilisateur et met à jour le mime.
	ConnectWebSocket	Joue le rôle de point de terminaison de client WebSocket pour interagir avec un serveur WebSocket distant.
	ConsumeAMQP	Consomme les messages AMQP d’un courtier AMQP à l’aide de AMQP 0.
	ConsumeAzureEventHub	Reçoit des messages de Microsoft Azure Event Hubs avec un mécanisme de points de contrôle garantissant un traitement cohérent des événements.
	ConsumeBoxEnterpriseEvents	Consomme les événements d’entreprise des flux Box de type admin_logs_streaming.
	ConsumeBoxEvents	Consomme tous les événements de Box.
	ConsumeElasticsearch	Un processeur qui exécute de manière répétée une requête paginée sur un champ à l’aide d’une requête Range pour consommer de nouveaux documents à partir d’un index/d’une requête Elasticsearch.
	ConsumeGCPubSub	Consomme les messages de l’abonnement configuré à Google Cloud PubSub.
	ConsumeIMAP	Consomme les messages du serveur de messagerie en utilisant le protocole IMAP.
	ConsumeJMS	Consomme un message JMS du type BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage, transforme son contenu en FlowFile et le transmet à la relation « success ».
	ConsumeKafka	Consomme les messages de l’API Apache Kafka Consumer.
	ConsumeKafka	Consomme les messages de l’API Apache Kafka Consumer.
	ConsumeKinesisStream	Lit les données du flux Kinesis AWS spécifié et génère un FlowFile pour chaque enregistrement traité (brut) ou un FlowFile pour un lot d’enregistrements traités si un lecteur d’enregistrements et un rédacteur d’enregistrements sont configurés.
	ConsumeMQTT	S’abonner à un sujet et recevoir des messages d’un broker MQTT
	ConsumePOP3	Consomme les messages du serveur de messagerie en utilisant le protocole POP3.
	ConsumeSlack	Récupère les messages d’un ou plusieurs canaux Slack configurés.
	ConsumeSlackConversation	Récupère les messages des conversations Slack disponibles pour l’application.
	ConsumeSlackHistory	Récupère l’historique des messages de tous les canaux Slack disponibles pour l’application.
	ConsumeSnowflakeStream	Récupère les données d’un flux Snowflake et les écrit sur un FlowFile.
	ConsumeTwitter	Diffuse des tweets à partir de l’API de streaming version 2 de Twitter.
	ControlRate	Contrôle le débit auquel les données sont transférées aux processeurs suivants.
	ConvertCharacterSet	Convertit le contenu d’un FlowFile d’un jeu de caractères à un autre
	ConvertRecord	Convertit les enregistrements d’un format de données à un autre à l’aide des Controller Services Record Reader et Record Writer configurés.
	ConvertToJournalSchema	Convertit le schéma de la base de données entrante en un schéma approprié pour une table Snowflake CDC Journal.
	CopyAzureBlobStorage_v12	Copie un blob présent dans le stockage Azure Blob d’un compte/conteneur à un autre.
	CopyS3Object	Copie un fichier d’un compartiment et d’une clé vers un autre dans AWS S3
	CountText	Calcule différentes métriques sur le texte entrant.
	CreateAmazonAdsReport	Processeur qui crée la configuration des rapports pour le connecteur Amazon Ads.
	CreateAzureOpenAiEmbeddings	Utilise Azure OpenAI pour créer des intégrations pour le texte.
	CreateBoxFileMetadataInstance	Crée une instance de métadonnées pour un fichier Box à l’aide d’un modèle spécifié avec des valeurs issues du contenu du FlowFile.
	CreateBoxMetadataTemplate	Crée un modèle de métadonnées Box à l’aide des spécifications de champ provenant du contenu du FlowFile.
	CreateCohereEmbeddings	Utilise Cohere pour créer des intégrations pour le texte.
	CreateMetaAdsReport	Processeur qui crée la configuration des rapports pour le connecteur Meta Ads.
	CreateOpenAiEmbeddings	Utilise OpenAI pour créer des intégrations pour le texte.
	CreateSnowflakeEmbeddings	Créer des intégrations vectorielles à l’aide de fonctions Snowflake Cortex Large Language Model
	CreateVertexAIEmbeddings	Utilise VertexAI pour créer des intégrations pour le texte.
	CryptographicHashContent	Calcule une valeur de hachage cryptographique pour le contenu du FlowFile à l’aide de l’algorithme donné et l’écrit dans un attribut de sortie.

D¶

	Processeur	Description
	DebugFlow	Le processeur DebugFlow facilite les tests et le débogage du cadre FlowFile en permettant de déclencher explicitement diverses réponses suite à la réception d’un FlowFile ou d’un événement de temporisateur sans FlowFile si vous utilisez une planification basée sur un temporisateur ou sur cron.
	DecryptContentAge	Déchiffre le contenu à l’aide de la spécification age-encryption.
	DecryptContentPGP	Déchiffrer le contenu de messages OpenPGP.
	DeduplicateRecord	Ce processeur dédouble les enregistrements individuels au sein d’un ensemble d’enregistrements.
	DeleteAzureBlobStorage_v12	Supprime le blob spécifié d’Azure Blob Storage.
	DeleteAzureDataLakeStorage	Supprime le fichier fourni d’Azure Data Lake Storage
	DeleteBoxFileMetadataInstance	Supprime une instance de métadonnées d’un fichier Box à l’aide de la clé de modèle spécifiée
	DeleteByQueryElasticsearch	Effectuer une suppression d’un index Elasticsearch à l’aide d’une requête.
	DeleteDBFSResource	Supprimer des fichiers et répertoires DBFS.
	DeleteDynamoDB	Supprime un document de DynamoDB en fonction d’une clé de hachage et d’intervalle.
	DeleteFile	Supprime un fichier du système de fichiers.
	DeleteGCSObject	Supprime des objets d’un compartiment Google Cloud.
	DeleteGridFS	Supprime un fichier de GridFS à l’aide d’un nom de fichier ou d’une requête.
	DeleteMilvus	Supprime des vecteurs de la base de données Milvus d’une collection par ID.
	DeleteMongo	Exécute une requête de suppression sur une collection MongoDB.
	DeletePinecone	Supprime les vecteurs d’un index Pinecone.
	DeleteQueryJob	Supprime une tâche de requête dans Salesforce à l’aide de la fonction Bulk API 2.
	DeleteS3Object	Supprime un fichier d’un compartiment Amazon S3.
	DeleteSFTP	Supprime un fichier résidant sur un serveur SFTP.
	DeleteSQS	Supprime un message d’une file d’attente Amazon Simple Queuing Service
	DeleteUnityCatalogResource	Supprimez un fichier ou un répertoire du catalogue Unity.
	DescribeDataShare	Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.
	DescribeSFDCObject	Décrire les métadonnées de l’objet spécifié dans Salesforce.
	DetectDuplicate	Met en cache une valeur, calculée à partir des attributs de FlowFile, pour chaque FlowFile entrant et détermine si la valeur mise en cache a déjà été vue.
	DistributeLoad	Distribue les FlowFiles aux transformateurs en aval sur la base d’une stratégie de distribution.
	DuplicateFlowFile	Destiné aux tests de charge, ce processeur créera le nombre configuré de copies de chaque FlowFile entrant.

E¶

	Processeur	Description
	EncodeContent	Encodez ou décodez le contenu d’un FlowFile à l’aide des schémas d’encodage Base64, Base32 ou hexadécimal
	EncryptContentAge	Chiffre le contenu à l’aide de la spécification age-encryption.
	EncryptContentPGP	Chiffrer le contenu à l’aide de OpenPGP.
	EnforceOrder	Renforce l’ordre attendu des FlowFiles qui appartiennent au même groupe de données au sein d’un même nœud.
	EnrichAttributes	Recherche une valeur à l’aide du service de recherche configuré et ajoute les résultats au FlowFile sous la forme d’un ou plusieurs attributs.
	EnrichCdcStream	Enrichit les FlowFiles entrants qui proviennent de CaptureChangePostgreSQL, etc.
	EvaluateJsonPath	Évalue une ou plusieurs expressions de JsonPath par rapport au contenu du FlowFile.
	EvaluateRagAnswerCorrectness	Évalue l’exactitude des réponses générées dans un contexte de génération assistée par la recherche (RAG) en calculant des mesures telles que le score F1, la similarité cosinusoïdale et l’exactitude de la réponse.
	EvaluateRagFaithfulness	Évalue la fidélité des réponses générées dans un système de génération augmentée de récupération (RAG) en analysant les réponses à l’aide d’un LLM (e.
	EvaluateRagRetrieval	Calcule les mesures de récupération (Precision@N, Recall@N, FScore@N, MAP@N, MRR) pour un système RAG en utilisant un LLM comme juge.
	EvaluateXPath	Évalue un ou plusieurs XPaths par rapport au contenu d’un FlowFile.
	EvaluateXQuery	Évalue un ou plusieurs XQueries par rapport au contenu d’un FlowFile.
	ExecuteGroovyScript	Processeur expérimental de scripts Groovy étendus.
	ExecuteProcess	Exécute une commande du système d’exploitation spécifiée par l’utilisateur et écrit la sortie de cette commande sur un FlowFile.
	ExecuteScript	Expérimental - Exécute un script à partir d’un fichier de flux et d’une session de traitement.
	ExecuteSQL	Exécute la requête SELECT fournie à SQL.
	ExecuteSQLRecord	Exécute la requête SELECT fournie à SQL.
	ExecuteSQLStatement	Exécute une instruction SQL DDL ou DML sur une base de données.
	ExecuteStreamCommand	Le processeur ExecuteStreamCommand offre un moyen souple d’intégrer des commandes et des scripts externes dans les flux de données de NiFi.
	ExtractAvroMetadata	Extrait les métadonnées de l’en-tête d’un fichier de données Avro.
	ExtractEmailAttachments	Extrayez les pièces jointes d’un fichier e-mail au format mime, en les divisant en fichiers de flux individuels.
	ExtractEmailHeaders	En utilisant le contenu du fichier de flux comme source de données, extrayez l’en-tête d’un fichier e-mail conforme RFC ajoutant les attributs pertinents au fichier de flux.
	ExtractGrok	Évalue une ou plusieurs expressions Grok par rapport au contenu d’un FlowFile, en ajoutant les résultats en tant qu’attributs ou en remplaçant le contenu du FlowFile par une notation JSON du contenu correspondant
	ExtractRecordSchema	Extrait le schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et l’écrit dans l’attribut “avro.
	ExtractSchemaColumns	Extrait les colonnes du schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et les écrit dans l’attribut ‘schema.
	ExtractStructuredBoxFileMetadata	Extrait les métadonnées d’un fichier Box à l’aide de Box AI.
	ExtractText	Évalue une ou plusieurs expressions régulières par rapport au contenu d’un FlowFile.

F¶

	Processeur	Description
	FetchAzureBlobStorage_v12	Récupère le blob spécifié dans Azure Blob Storage et écrit son contenu dans le contenu du FlowFile.
	FetchAzureDataLakeStorage	Récupérer le fichier spécifié à partir du stockage Azure Data Lake
	FetchBoxFile	Récupère les fichiers d’un dossier Box.
	FetchBoxFileInfo	Récupère les métadonnées des fichiers dans Box et les ajoute aux attributs du FlowFile.
	FetchBoxFileMetadataInstance	Récupère une instance de métadonnées spécifique associée à un fichier Box à l’aide d’une clé de modèle et d’un champ d’application.
	FetchBoxFileRepresentation	Extrait la représentation d’un fichier Box à l’aide d’un indice de représentation et l’écrit dans le contenu du FlowFile.
	FetchDatabaseMetadata	Récupère les métadonnées complètes de la base de données pour toutes les tables et les génère dans un FlowFile.
	FetchDistributedMapCache	Calcule la (les) clé(s) de cache à partir des attributs du FlowFile, pour chaque FlowFile entrant, et récupère(nt) la (les) valeur(s) du mappage distribué associée(s) à chaque clé.
	FetchDropbox	Récupère des fichiers dans Dropbox.
	FetchFile	Lit le contenu d’un fichier sur le disque et le transfère en flux dans le contenu d’un FlowFile entrant.
	FetchFTP	Récupère le contenu d’un fichier sur un serveur FTP distant et remplace le contenu d’un FlowFile entrant par le contenu du fichier distant.
	FetchGCSObject	Récupère un fichier à partir d’un compartiment de Google Cloud.
	FetchGoogleDrive	Récupère des fichiers à partir d’un dossier Google Drive.
	FetchGoogleDriveFileComments	Récupère les commentaires et leurs réponses dans un fichier Google Drive.
	FetchGoogleDriveMetadata	Récupère les métadonnées des fichiers de Google Drive.
	FetchGridFS	Récupère un ou plusieurs fichiers d’un compartiment GridFS par nom de fichier ou par requête définie par l’utilisateur.
	FetchJiraFields	Récupère des métadonnées complètes pour tous les champs disponibles dans l’instance Jira Cloud à l’aide du point de terminaison de champ/v3 de l’API REST.
	FetchJiraIssues	Récupère les problèmes dans Jira Cloud à l’aide de l’API REST v3 avec des options de recherche configurables.
	FetchMicrosoftDataverseTable	Récupérer des enregistrements dans les tables Microsoft Dataverse
	FetchS3Object	Récupère le contenu d’un objet S3 et l’écrit dans le contenu d’un FlowFile
	FetchSFTP	Récupère le contenu d’un fichier sur un serveur SFTP distant et remplace le contenu d’un FlowFile entrant par le contenu du fichier distant.
	FetchSharepointFile	Récupère le contenu d’un fichier à partir d’un lecteur Sharepoint, en téléchargeant éventuellement une version PDF ou HTML du fichier, le cas échéant.
	FetchSharepointMetadata	Pour chaque lecteur, l’élément récupère ses métadonnées et ses autorisations et les écrit sous forme d’attributs FlowFile.
	FetchSlackConversationInfo	Récupère les infos des conversations Slack et les emails des membres
	FetchSlackFile	Télécharge un fichier partagé sur Slack.
	FetchSlackMessage	Récupère les données relatives à un seul message Slack
	FetchSmb	Récupère des fichiers à partir d’un partage SMB.
	FetchSnowflakeTableProperties	Lit les propriétés d’une table et les stocke en tant qu’attributs du FlowFile.
	FetchSourceTableSchema	Récupère le schéma de la table (i.
	FetchTableSnapshot	Extrait un instantané d’une table d’une base de données.
	FilterAttribute	Filtre les attributs d’un FlowFile en conservant les attributs spécifiés et en supprimant le reste ou en supprimant les attributs spécifiés et en conservant le reste.
	FindConfluencePages	Processeur pour trouver les pages Confluence en utilisant le nom de l’espace et le nom de la page.
	FindSharepointDriveItem	Trouve un élément de Drive Sharepoint par son ID de lecteur et le chemin de l’élément.
	FlattenJson	Donne à l’utilisateur la possibilité de prendre une documentation JSON imbriquée et de l’aplatir en un simple document de paires clé/valeur.
	ForkEnrichment	Utilisé conjointement avec le processeur JoinEnrichment, ce processeur est chargé d’ajouter les attributs nécessaires à l’accomplissement de la fonction du processeur JoinEnrichment.
	ForkRecord	Ce processeur permet à l’utilisateur de diviser un enregistrement en plusieurs enregistrements.

G¶

	Processeur	Description
	GenerateAnswersFromContext	Génère des réponses synthétiques pour chaque question présente dans les enregistrements entrants à l’aide d’un grand modèle de langage (LLM).
	GenerateAnswersFromGroundTruth	Génère des réponses synthétiques pour chaque question des enregistrements entrants à l’aide d’un LLM.
	GenerateFlowFile	Ce processeur crée des FlowFiles avec des données aléatoires ou un contenu personnalisé.
	GenerateJSON	Produit un lot d’objets JSON avec des valeurs de champ aléatoires basées sur un schéma JSON configurable.
	GenerateRecord	Ce processeur crée des FlowFiles avec des enregistrements dont les valeurs des champs spécifiés sont aléatoires.
	GenerateTableFetch	Génère des requêtes SQL SELECT qui récupèrent des « pages » de lignes d’une table.
	GeoEnrichIP	Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile.
	GeoEnrichIPRecord	Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile.
	GetAmazonAdsReport	Le processeur télécharge le rapport des publicités Amazon s’il est prêt.
	GetAwsPollyJobStatus	Récupère le statut actuel d’une tâche AWS Polly.
	GetAwsTextractJobStatus	Récupère le statut actuel d’un travail AWS Textract.
	GetAwsTranscribeJobStatus	Récupère le statut actuel d’une tâche AWS Transcribe.
	GetAwsTranslateJobStatus	Récupère le statut actuel d’une tâche AWS Translate.
	GetAzureEventHub	Reçoit des messages provenant de Microsoft Azure Event Hubs sans suivi fiable des points de contrôle.
	GetAzureQueueStorage_v12	Récupère les messages à partir d’un stockage Azure Queue Storage.
	GetBoxFileCollaborators	Récupère tous les collaborateurs d’un fichier Box et ajoute les informations de collaboration aux attributs de FlowFile.
	GetBoxGroupMembers	Récupère les membres d’un groupe Box et écrit leurs détails dans les attributs FlowFile.
	GetConfluenceAuditRecords	Liste des processeurs d’enregistrements d’audit de Confluence.
	GetConfluenceGroupUsers	Processeur qui télécharge des informations sur les utilisateurs appartenant à un groupe Confluence donné
	GetConfluencePageContent	Processeur téléchargeant les pages Confluence.
	GetConfluencePageIds	Télécharge les pages Confluence modifiées depuis la dernière synchronisation et génère chacune d’entre elles sous la forme d’un FlowFile avec des métadonnées.
	GetConfluencePagePermissions	Processeur téléchargeant les autorisations de la page Confluence.
	GetConfluenceSpaceIds	Processeur pour la récupération des identifiants d’espaces Confluence.
	GetConfluenceSpacePermissions	Processeur téléchargeant les autorisations d’espaces Confluence.
	GetDataShareCredentials	Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.
	GetDataShareTables	Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud.
	GetDBFSFile	Lire un fichier DBFS.
	GetDynamoDB	Récupère un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle.
	GetElasticsearch	Processeur d’extraction Elasticsearch qui utilise les bibliothèques client officielles Elastic REST pour extraire un document unique d’Elasticsearch par _id.
	GetFile	Crée FlowFiles à partir des fichiers d’un répertoire.
	GetFileResource	Ce processeur crée des FlowFiles avec le contenu de la ressource fichier configurée.
	GetFTP	Récupère les fichiers d’un serveur FTP et crée les FlowFiles à partir de ces fichiers
	GetGcpVisionAnnotateFilesOperationStatus	Récupère le statut actuel d’une opération Google Vision.
	GetGcpVisionAnnotateImagesOperationStatus	Récupère le statut actuel d’une opération Google Vision.
	GetGoogleAdsReport	Un processeur qui peut interagir avec Google Ads Reporting API.
	GetGoogleGroupMembers	Récupère les membres d’un ou de plusieurs groupes Google, spécifiés sous la forme d’une liste d’IDs de groupe séparés par des virgules et donnés comme attribut FlowFile.
	GetGoogleSheets	Processeur chargé d’extraire les données de Google Sheets.
	GetHubSpot	Récupère les données JSON à partir d’une application privée HubSpot.
	GetHubSpotObject	Obtenir un objet HubSpot et ses associations par ID ou par valeur unique.
	GetHubSpotSchema	Récupère les informations de schéma pour les types d’objets HubSpot, y compris les noms de champ, les types et les libellés.
	GetLinkedInAdsReport	Le processeur télécharge des mesures à partir des APIs LinkedIn Reporting.
	GetMicrosoft365GroupMembers	Récupère les membres du groupe Microsoft365 et émet un FlowFile pour chaque changement survenu.
	GetMongo	Crée des FlowFiles à partir de documents de MongoDB chargés par une requête spécifiée par l’utilisateur.
	GetMongoRecord	Une version de GetMongo basée sur les enregistrements qui utilise les Record Writers pour écrire le jeu de résultats de MongoDB.
	GetQueryJobResult	Obtient les résultats d’une requête dans Salesforce à l’aide de la fonction Bulk API 2.
	GetQueryJobStatus	Obtient le statut d’une requête dans Salesforce à l’aide de la fonction Bulk API 2.
	GetS3ObjectMetadata	Vérifie l’existence d’un objet dans S3 et récupère ses métadonnées sans tenter de le télécharger.
	GetS3ObjectTags	Vérifie l’existence d’un objet dans S3 et récupère ses balises sans tenter de le télécharger.
	GetSFTP	Récupère les fichiers d’un serveur SFTP et crée les FlowFiles à partir de ces fichiers
	GetSharepointSiteGroupMembers	Récupère tous les membres d’un groupe de sites SharePoint.
	GetShopify	Récupère les objets d’une boutique Shopify personnalisée.
	GetSmbFile	Lit un fichier à partir d’un emplacement du réseau samba sur des FlowFiles.
	GetSplunk	Récupère les données de Splunk Enterprise.
	GetSQS	Récupère les messages d’une file d’attente Amazon Simple Queuing Service
	GetUnityCatalogFile	Lit un fichier Unity Catalog jusqu’à 5 GiB.
	GetUnityCatalogFileMetadata	Vérifie les métadonnées du fichier Unity Catalog.
	GetWorkdayReport	Un processeur qui peut interagir avec un rapport Workday configurable.
	GetZendesk	Récupère de manière incrémentale les données de Zendesk API.

H¶

	Processeur	Description
	HandleHttpRequest	Démarre un serveur HTTP et écoute les requêtes HTTP.
	HandleHttpResponse	Envoie une réponse HTTP au demandeur qui a généré un FlowFile.

I¶

	Processeur	Description
	IdentifyMimeType	Tente d’identifier le type MIME utilisé pour un FlowFile.
	InvokeHTTP	Un processeur client HTTP qui peut interagir avec un point de terminaison HTTP configurable.
	InvokeScriptedProcessor	Expérimental - Invoque un moteur de script pour un processeur défini dans le script donné.
	ISPEnrichIP	Recherche les informations de ISP pour une adresse IP et ajoute les informations aux attributs de FlowFile.

J¶

	Processeur	Description
	JoinEnrichment	Réunit des enregistrements provenant de deux FlowFiles différents, dont l’un, FlowFile original, contient des enregistrements arbitraires et l’autre, FlowFile d’enrichissement, contient des données supplémentaires à utiliser pour enrichir le premier.
	JoltTransformJSON	Applique une liste de spécifications Jolt au contenu de FlowFile JSON, ou à un attribut spécifié de FlowFile JSON.
	JoltTransformRecord	Applique une spécification JOLT à chaque enregistrement de la charge utile FlowFile.
	JSLTTransformJSON	Applique une transformation JSLT à la charge utile FlowFile JSON.
	JsonQueryElasticsearch	Un processeur qui permet à l’utilisateur d’exécuter une requête (avec des agrégations) écrite avec Elasticsearch JSON DSL.

L¶

	Processeur	Description
	ListArchivedHubSpotData	Répertorie les données archivées sur HubSpot pour le type d’objet choisi et génère un FlowFile par objet répertorié avec les métadonnées correspondantes en tant qu’attributs FlowFile.
	ListAzureBlobStorage_v12	Établit la liste des blobs dans un conteneur de stockage Azure Blob.
	ListAzureDataLakeStorage	Liste le répertoire dans un système de fichiers Azure Data Lake Storage Gen 2
	ListBoxFile	Liste les fichiers d’un dossier Box.
	ListBoxFileInfo	Récupère les métadonnées de chaque fichier d’un dossier Box.
	ListBoxFileMetadataInstances	Récupère toutes les instances de métadonnées associées à un fichier Box.
	ListBoxFileMetadataTemplates	Récupère tous les modèles de métadonnées associés à un fichier Box.
	ListConfluenceGroups	Processeur répertoriant les groupes Confluence.
	ListDatabaseTables	Génère un ensemble de FlowFiles, chacun contenant des attributs correspondant aux métadonnées d’une table à partir d’une connexion à la base de données.
	ListDBFSDirectory	Liste les noms de fichiers dans un répertoire DBFS et génère un nouveau FlowFile en sortie avec le nom du fichier.
	ListDropbox	Récupère un listing de fichiers à partir de Dropbox (les raccourcis sont ignorés).
	ListenFTP	Démarre un serveur FTP qui écoute sur le port spécifié et transforme les fichiers entrants en FlowFiles.
	ListenHTTP	Démarre un serveur HTTP et écoute sur un chemin de base donné pour transformer les requêtes entrantes en FlowFiles.
	ListenOTLP	Collecte les messages OpenTelemetry sur HTTP ou gRPC.
	ListenSlack	Récupère les messages en temps réel ou les commandes Slack d’une ou plusieurs conversations Slack.
	ListenSyslog	Écoute des messages Syslog envoyés à un port donné via TCP ou UDP.
	ListenTCP	Écoute les connexions TCP entrantes et lit les données de chaque connexion en utilisant un séparateur de ligne comme délimiteur de message.
	ListenUDP	Écoute des paquets de datagrammes sur un port donné.
	ListenUDPRecord	Écoute les paquets de datagrammes sur un port donné et lit le contenu de chaque datagramme à l’aide du Record Reader configuré.
	ListenWebSocket	Joue le rôle de point de terminaison du serveur WebSocket pour accepter les connexions client.
	ListFile	Récupère une liste de fichiers dans le répertoire d’entrée.
	ListFTP	Effectue une liste des fichiers résidant sur un serveur FTP.
	ListGCSBucket	Récupère une liste d’objets dans un compartiment GCS.
	ListGoogleDrive	Effectue une liste des fichiers concrets (les raccourcis sont ignorés) dans un dossier Google Drive.
	ListGoogleDriveFileInfo	Établit la liste de tous les fichiers et dossiers d’un Google Drive spécifié.
	ListGoogleGroups	Répertorie tous les groupes d’un domaine donné dans Google Workspace.
	ListHubSpotObjects	Extrait les données de HubSpot pour les types d’objets spécifiés et génère un FlowFile par objet répertorié avec les métadonnées correspondantes en tant qu’attributs de FlowFile.
	ListMicrosoftDataverseTables	Tables de liste des environnements Microsoft Dataverse
	ListS3	Récupère une liste d’objets à partir d’un compartiment S3.
	ListSFDCDataShares	Dresse la liste des partages de données disponibles dans l’organisation et accessibles à l’utilisateur identifié.
	ListSFDCObjects	Liste des objets disponibles dans l’organisation et accessibles à l’utilisateur identifié.
	ListSFTP	Effectue une liste des fichiers résidant sur un serveur SFTP.
	ListSharepointDrives	Émet un FlowFile pour chaque lecteur présent dans le site Sharepoint spécifié.
	ListSharepointSiteGroups	Liste tous les groupes de sites SharePoint disponibles sur un site SharePoint spécifié.
	ListSmb	Liste des fichiers concrets partagés via le protocole SMB.
	ListTableNames	Récupère tous les noms de tables sources et les associe à l’une des configurations possibles : - regexp expression e.
	ListUnityCatalogDirectory	Répertorie les noms de fichiers dans un répertoire du catalogue Unity et génère une nouvelle page FlowFile avec le nom du fichier en sortie.
	LogAttribute	Émet les attributs de FlowFile au niveau de journalisation spécifié
	LogMessage	Émet un message de journalisation au niveau de journalisation spécifié
	LookupAttribute	Recherche d’attributs à partir d’un service de consultation
	LookupRecord	Extrait un ou plusieurs champs d’un enregistrement et recherche une valeur pour ces champs dans LookupService.

M¶

	Processeur	Description
	MergeContent	Fusionne un groupe de FlowFiles sur la base d’une stratégie définie par l’utilisateur et les regroupe en un seul FlowFile.
	MergeRecord	Ce processeur fusionne plusieurs enregistrements FlowFiles en un seul FlowFile qui contient tous les enregistrements du FlowFiles en entrée.
	MergeSnowflakeJournalTable	Déclenche une opération de fusion sur les modifications de la table du journal vers une table de destination dans Snowflake.
	ModifyBytes	Rejette une plage d’octets au début et à la fin ou tout le contenu d’un fichier binaire.
	ModifyCompression	Modifie l’algorithme de compression utilisé pour compresser le contenu d’un FlowFile en décompressant le contenu des FlowFiles via un algorithme de compression spécifié par l’utilisateur et en recompressant le contenu à l’aide des propriétés du format de compression spécifiées.
	MonitorActivity	Surveille l’activité du flux et envoie un indicateur lorsque le flux n’a pas reçu de données pendant une période donnée, puis à nouveau lorsque l’activité du flux est rétablie
	MoveAzureDataLakeStorage	Déplace le contenu au sein d’un Azure Data Lake Storage Gen 2.

N¶

	Processeur	Description
	Notify	Met en cache un identificateur de signal de version dans le cache distribué, éventuellement avec les attributs du FlowFile.

O¶

	Processeur	Description
	OpenAiTranscribeAudio	Procède à la transcription du son en texte anglais.

P¶

	Processeur	Description
	PackageFlowFile	Ce processeur regroupera les attributs et le contenu de FlowFile dans unFlowFile en sortie qui peut être exporté de NiFi et réimporté dans NiFi, en préservant les attributs et le contenu d’origine.
	PaginatedJsonQueryElasticsearch	Un processeur qui permet à l’utilisateur d’exécuter une requête paginée (avec agrégations) écrite avec Elasticsearch JSON DSL.
	ParseEvtx	Analyse le contenu d’un fichier du journal des événements Windows (evtx) et écrit l’adresse XML qui en résulte dans le FlowFile
	ParseExcelCellReference	Processeur responsable de l’analyse des formules de référence des cellules Excel.
	ParseSyslog	Tente d’analyser le contenu d’un message Syslog conformément aux formats RFC5424 et RFC3164 et ajoute des attributs au FlowFile pour chacune des parties du message Syslog.
	ParseSyslog5424	Tente d’analyser le contenu d’un message Syslog conforme au format RFC5424 et ajoute des attributs au FlowFile pour chacune des parties du message Syslog, y compris les données structurées.
	PartitionRecord	Fractionne, ou partitionne, les données orientées enregistrement en fonction des champs configurés dans les données.
	PerformSnowflakeCortexOCR	Effectue la reconnaissance optique des caractères (OCR) sur les documents PDF en utilisant les fonctions ML du Snowflake Cortex.
	PickTablesForReplication	Accepte une liste de noms de table pleinement qualifiés et détermine si une table : - est nouvelle (n’est pas répliquée, mais a été ajoutée dans la source) - est existante (est répliquée et existe dans la source) - est obsolète (est répliquée mais n’existe plus dans la source) La configuration est transmise en tant qu’attribut de FlowFile.
	PromptAnthropicAI	Envoie une invite à Anthropic, en écrivant la réponse sous forme d’attribut FlowFile ou dans le contenu du FlowFile entrant.
	PromptAzureOpenAI	Envoie une invite au service OpenAI d’Azure, en écrivant la réponse soit sous forme d’attribut FlowFile, soit dans le contenu du FlowFile entrant.
	PromptLLM	Ce processeur envoie une invite définie par l’utilisateur à un Large Language Model (LLM) pour qu’il y réponde.
	PromptOpenAI	Envoie une invite à OpenAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant.
	PromptSnowflakeCortex	Envoie une demande à Snowflake Cortex, en écrivant la réponse sous la forme d’un attribut FlowFile ou dans le contenu du FlowFile entrant.
	PromptVertexAI	Envoie une invite à VertexAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant.
	PublishAMQP	Crée un message AMQP à partir du contenu d’un FlowFile et envoie le message à un échange AMQP.
	PublishGCPubSub	Publie le contenu du FlowFile entrant dans la rubrique configurée de Google Cloud PubSub.
	PublishJMS	Crée un message JMS à partir du contenu d’un FlowFile et l’envoie à une destination JMS (file d’attente ou sujet) en tant que BytesMessage ou TextMessage JMS.
	PublishKafka	Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API.
	PublishKafka	Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API.
	PublishMQTT	Publie un message sur un sujet MQTT
	PublishSlack	Publie un message sur le canal Slack spécifié.
	PutAzureBlobStorage_v12	Place le contenu dans un blob sur Azure Blob Storage.
	PutAzureCosmosDBRecord	Ce processeur est un processeur d’enregistrement pour l’insertion de données dans Cosmos DB avec Core SQL API.
	PutAzureDataExplorer	Agit comme un puits Azure Data Explorer qui envoie des FlowFiles au point de terminaison fourni.
	PutAzureDataLakeStorage	Écrit le contenu d’un FlowFile en tant que fichier sur Azure Data Lake Storage Gen 2
	PutAzureEventHub	Envoie le contenu de FlowFile sur Azure Event Hubs
	PutAzureQueueStorage_v12	Écrit le contenu des FlowFiles entrants dans le stockage Azure Queue Sorage configuré.
	PutBigQuery	Écrit le contenu d’un FlowFile dans une table Google BigQuery.
	PutBoxFile	Place le contenu dans un dossier Box.
	PutCloudWatchMetric	Publie les métriques sur Amazon CloudWatch.
	PutDatabaseRecord	Le processeur PutDatabaseRecord utilise un RecordReader spécifié pour utiliser en entrée des enregistrements (éventuellement multiples) à partir d’un FlowFile entrant.
	PutDatabricksSQL	Soumet une exécution SQL à l’aide de Databricks REST API puis écrit la réponse JSON dans le contenu du FlowFile.
	PutDBFSFile	Rédige le contenu de FlowFile sur DBFS.
	PutDistributedMapCache	Récupère le contenu d’un FlowFile et le place dans un cache de carte distribué, en utilisant une clé de cache calculée à partir des attributs de FlowFile.
	PutDropbox	Place le contenu dans un dossier Dropbox.
	PutDynamoDB	Place un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle.
	PutDynamoDBRecord	Insère des éléments dans DynamoDB sur la base de données orientées enregistrement.
	PutElasticsearchJson	Un processeur de mise en place d’Elasticsearch qui utilise les bibliothèques client officielles d’Elastic REST.
	PutElasticsearchRecord	Un processeur de mise en place d’Elasticsearch tenant compte des enregistrements et utilisant les bibliothèques client officielles d’Elastic REST.
	PutEmail	Envoi d’un courrier électronique aux destinataires configurés pour chaque FlowFile entrant
	PutFile	Écrit le contenu d’un FlowFile dans le système de fichiers local
	PutFTP	Envoie des FlowFiles à un serveur FTP
	PutGCSObject	Écrit le contenu d’un FlowFile en tant qu’objet dans un Google Cloud Storage.
	PutGoogleDrive	Rédige le contenu d’un FlowFile sous forme de fichier dans Google Drive.
	PutGridFS	Écrit un fichier dans un compartiment GridFS.
	PutHubSpot	Insertion d’un objet HubSpot.
	PutIcebergTable	Stocke les enregistrements dans Iceberg à l’aide d’un catalogue configurable pour la gestion des espaces de noms et des tables.
	PutKinesisFirehose	Envoie le contenu vers un Amazon Kinesis Firehose spécifié.
	PutKinesisStream	Envoie le contenu à un Amazon Kinesis spécifié.
	PutLambda	Envoie le contenu à une fonction Amazon Lambda spécifiée.
	PutMongo	Écrit le contenu d’un FlowFile sur MongoDB
	PutMongoBulkOperations	Écrit le contenu d’un FlowFile sur MongoDB en tant que bulk-update
	PutMongoRecord	Ce processeur est un processeur d’enregistrement pour l’insertion/la réinsertion de données dans MongoDB.
	PutRecord	Le processeur PutRecord utilise un RecordReader spécifié pour retourner des enregistrements (éventuellement multiples) à partir d’un FlowFile entrant, et les envoie vers une destination spécifiée par un service de destination (i.
	PutRedisHashRecord	Place les données des champs de l’enregistrement dans Redis en utilisant une valeur de hachage spécifiée, qui est déterminée par un RecordPath vers un champ contenant la valeur de hachage.
	PutS3Object	Écrit le contenu d’un FlowFile en tant qu’objet S3 dans un compartiment Amazon S3 Bucket.
	PutSalesforceObject	Crée de nouveaux enregistrements pour l’objet Salesforce sObject spécifié.
	PutSFTP	Envoie des FlowFiles à un serveur SFTP
	PutSmbFile	Écrit le contenu d’un FlowFile à un emplacement du réseau samba.
	PutSnowflakeInternalStageFile	Place les fichiers dans une zone de préparation interne de Snowflake.
	PutSnowpipeStreaming	Diffuse les enregistrements dans une table Snowflake.
	PutSnowpipeStreaming2	Envoyer des enregistrements au format JSON délimité par des sauts de ligne vers les canaux de la base de données Snowflake à l’aide de Snowpipe Streaming version 2.
	PutSNS	Envoie le contenu d’un FlowFile sous forme de notification à Amazon Simple Notification Service
	PutSplunk	Envoie les journaux à Splunk Enterprise via TCP, TCP + TLS/SSL, ou UDP.
	PutSplunkHTTP	Envoie le contenu du FlowFile au serveur Splunk spécifié via HTTP ou HTTPS.
	PutSQL	Exécute une commande SQL UPDATE ou INSERT.
	PutSQS	Publie un message dans une file d’attente d’Amazon Simple Queuing Service
	PutSyslog	Envoie des messages Syslog à un hôte et à un port donnés via TCP ou UDP.
	PutTCP	Envoi de FlowFiles ou d’enregistrements sérialisés sur TCP vers une destination configurable avec prise en charge optionnelle de TLS
	PutUDP	Le processeur PutUDP reçoit un FlowFile et regroupe le contenu FlowFile en un seul paquet de datagrammes UDP qui est ensuite transmis au serveur UDP configuré.
	PutUnityCatalogFile	Rédige le contenu de FlowFile avec une taille maximale de 5 GiB pour Unity Catalog.
	PutVectaraDocument	Génère et télécharge une documentation JSON vers le point de terminaison de Vectara.
	PutVectaraFile	Télécharge un contenu FlowFile sur l’index du point de terminaison de Vectara.
	PutWebSocket	Envoi de messages à un point de terminaison distant WebSocket à l’aide d’une session WebSocket établie par ListenWebSocket ou ConnectWebSocket.
	PutZendeskTicket	Crée des tickets Zendesk à l’aide de Zendesk API.

Q¶

	Processeur	Description
	QueryAzureDataExplorer	Interroge Azure Data Explorer et diffuse les résultats JSON vers les FlowFiles en sortie
	QueryDatabaseTable	Génère une requête SQL select, ou utilise une instruction fournie et l’exécute pour récupérer toutes les lignes dont les valeurs dans la (les) colonne(s) Valeur maximale spécifiée(s) sont plus grandes que les maxima précédemment observées.
	QueryDatabaseTableRecord	Génère une requête SQL select, ou utilise une instruction fournie et l’exécute pour récupérer toutes les lignes dont les valeurs dans la (les) colonne(s) Valeur maximale spécifiée(s) sont plus grandes que les maxima précédemment observées.
	QueryMilvus	Effectue la requête d’une collection donnée dans une base de données Milvus à l’aide de vecteurs.
	QueryPinecone	Interroge Pinecone sur les vecteurs similaires au vecteur d’entrée, ou récupère un vecteur par ID.
	QueryRecord	Évalue une ou plusieurs requêtes SQL par rapport au contenu d’un FlowFile.
	QuerySalesforceObject	Récupère les enregistrements d’un objet Salesforce sObject.
	QuerySplunkIndexingStatus	Interroge le serveur Splunk afin d’obtenir le statut de l’accusé de réception de l’indexation.

R¶

	Processeur	Description
	RemoveRecordField	Modifie le contenu d’un FlowFile qui contient des données orientées enregistrement (i.
	RenameRecordField	Renomme un ou plusieurs champs dans chaque enregistrement d’un FlowFile.
	ReplaceText	Met à jour le contenu d’un FlowFile en recherchant une certaine valeur textuelle dans le contenu du FlowFile (par le biais d’une expression régulière/regex ou d’une valeur littérale) et en remplaçant la section du contenu correspondqnt par une autre valeur.
	ReplaceTextWithMapping	Met à jour le contenu d’un FlowFile en évaluant une expression régulière et en remplaçant la section du contenu qui correspond à l’expression régulière par une autre valeur fournie dans un fichier de mappage.
	RetryFlowFile	Les FlowFiles transmis à ce processeur ont une valeur « Retry Attribute » vérifiée par rapport à une valeur « « Maximum Retries » configurée.
	RouteOnAttribute	Route lesattribut FlowFiles en fonction de leurs attributs à l’aide de Attribute Expression Language
	RouteOnContent	Applique des expressions régulières au contenu d’un FlowFile et route une copie du FlowFile vers chaque destination avec une expression régulière correspondante.
	RouteText	Route des données textuelles sur la base d’un ensemble de règles définies par l’utilisateur.
	RunDatabricksJob	Déclenche l’exécution d’un travail Databricks prédéfini avec des paramètres personnalisés.
	RunMongoAggregation	Un processeur qui exécute une requête d’agrégation chaque fois qu’il reçoit un FlowFile.

S¶

	Processeur	Description
	SampleRecord	Échantillonne les enregistrements d’un FlowFile sur la base d’une stratégie d’échantillonnage spécifiée (telle que l’échantillonnage de réservoir).
	ScanAttribute	Analyse les attributs spécifiés de FlowFiles, en vérifiant si l’une de leurs valeurs est présente dans le dictionnaire de termes spécifié
	ScanContent	Recherche dans le contenu de FlowFiles les termes qui se trouvent dans un dictionnaire fourni par l’utilisateur.
	ScriptedFilterRecord	Ce processeur offre la possibilité de filtrer les enregistrements à partir de FlowFiles à l’aide du script fourni par l’utilisateur.
	ScriptedPartitionRecord	Reçoit des données orientées enregistrement (i.
	ScriptedTransformRecord	Fournit la possibilité d’évaluer un script simple pour chaque enregistrement d’un FlowFile entrant.
	ScriptedValidateRecord	Ce processeur offre la possibilité de valider les enregistrements dans les FlowFiles à l’aide du script fourni par l’utilisateur.
	SearchElasticsearch	Un processeur qui permet à l’utilisateur d’exécuter de manière répétée une requête paginée (avec agrégations) écrite avec Elasticsearch JSON DSL.
	SegmentContent	Segmente un FlowFile en plusieurs segments plus petits dans la limite des octets.
	SignContentPGP	Signe le contenu à l’aide des clés privées de OpenPGP
	SnowflakeDetectDuplicate	Vérifie si le hachage d’un FlowFile (fourni sous la forme d’un attribut FlowFile) est déjà dans une table Snowflake, et achemine le FlowFile vers “dupliquer” si trouvé, “distinct” si non trouvé, ou “échec” pour les erreurs.
	SplitAvro	Divise un fichier de données Avro codé en binaire en plusieurs fichiers plus petits en fonction de la taille de sortie configurée.
	SplitContent	Fractionne les FlowFiles entrants en fonction d’une séquence d’octets spécifiée
	SplitExcel	Ce processeur divise une feuille de calcul Microsoft Excel à plusieurs feuilles en plusieurs feuilles de calcul Microsoft Excel où chaque feuille du fichier d’origine est convertie en une feuille de calcul individuelle dans son propre FlowFile.
	SplitJson	Fractionne un fichier JSON en plusieurs FlowFiles distincts pour un élément de tableau spécifié par une expression JsonPath.
	SplitRecord	Fractionne unFlowFile en entrée au format de données orienté enregistrement en plusieurs FlowFiles plus petits
	SplitText	Fractionne un fichier texte en plusieurs fichiers texte plus petits sur des lignes limitées en nombre maximum de lignes ou en taille totale du fragment.
	SplitXml	Fractionne un fichier XML en plusieurs FlowFiles distincts, chacun comprenant un enfant ou un descendant de l’élément racine d’origine
	StartAwsPollyJob	Déclenche une tâche AWS Polly.
	StartAwsTextractJob	Déclenche une tâche AWS Textract.
	StartAwsTranscribeJob	Déclenche une tâche AWS Transcribe.
	StartAwsTranslateJob	Déclenche une tâche AWS Translate.
	StartGcpVisionAnnotateFilesOperation	Déclenche une opération Vision sur un fichier en entrée.
	StartGcpVisionAnnotateImagesOperation	Déclenche une opération Vision sur une image en entrée.
	SubmitQueryJob	Soumet une requête à Salesforce à l’aide de la fonction Bulk API 2.
	SummarizeText	Ce processeur utilise un Large Language Model (LLM) pour résumer le contenu d’un FlowFile.

T¶

	Processeur	Description
	TagS3Object	Ajoute ou met à jour une balise sur un objet Amazon S3.
	TailFile	Affiche la fin d’un fichier ou d’une liste de fichiers via la commande « Tail », en ingérant les données du fichier au fur et à mesure qu’elles y sont écrites.
	TransformXml	Applique le fichier XSLT fourni à la charge utile XML du FlowFile.

U¶

	Processeur	Description
	UnpackContent	Décompresse le contenu des FlowFiles emballés avec l’un des différents formats d’empaquetage, en émettant un à plusieurs FlowFiles pour chaque FlowFile en entrée.
	UpdateAttribute	Met à jour les attributs d’un FlowFile en utilisant Attribute Expression Language et/ou supprime les attributs sur la base d’une expression régulière
	UpdateBoxFileMetadataInstance	Met à jour les valeurs du modèle de métadonnées pour un fichier Box en utilisant l’enregistrement dans le FlowFile donné.
	UpdateBulkJobState	Met à jour le statut d’une tâche groupée Salesforce dans le service d’état partagé pour un type d’objet spécifique
	UpdateByQueryElasticsearch	Met à jour les documents d’un index Elasticsearch à l’aide d’une requête.
	UpdateCounter	Ce processeur permet aux utilisateurs de définir des paramètres spécifiques et des points clés dans leur flux.
	UpdateDatabaseTable	Ce processeur utilise une connexion JDBC et des enregistrements entrants pour générer toutes les modifications des tables de la base de données nécessaires à la prise en charge des enregistrements entrants.
	UpdateRecord	Met à jour le contenu d’un FlowFile qui contient des données orientées enregistrement (i.
	UpdateSnowflakeDatabase	Met à jour la définition d’une table Snowflake sur la base du schéma fourni dans le FlowFile entrant.
	UpdateSnowflakeIcebergDatabase	Met à jour la définition d’une table Snowflake Iceberg.
	UpdateSnowflakeSchema	Crée un schéma de base de données Snowflake s’il n’existe pas.
	UpdateSnowflakeStream	Gère les flux Snowflake en les créant, en les supprimant ou en les remplaçant en fonction de l’opération configurée.
	UpdateSnowflakeTable	Met à jour la définition d’une table Snowflake sur la base du schéma fourni dans le FlowFile entrant.
	UpdateSnowflakeView	Crée ou remplace des vues Snowflake en fonction des mappages de colonnes fournis dans les FlowFile entrants.
	UpdateTableState	Met à jour l’état d’une table dans le service d’état des tables
	UpsertMilvus	Insère les vecteurs dans la base de données Milvus pour une collection donnée
	UpsertPinecone	Publie les vecteurs, y compris les métadonnées, et éventuellement le texte, dans un index Pinecone.
	UpsertSFDCObjects	Insère via Upsert les enregistrements provenant du FlowFile dans Salesforce

V¶

	Processeur	Description
	ValidateCsv	Valide le contenu des FlowFiles ou une valeur d’attribut de FlowFile par rapport à un schéma CSV spécifié par l’utilisateur.
	ValidateJson	Valide le contenu des FlowFiles par rapport à un schéma JSON configurable.
	ValidateRecord	Valide les enregistrements d’un FlowFile entrant par rapport à un schéma donné.
	ValidateXml	Valide le contenu XML dans un FlowFile.
	VerifyContentMAC	Calcule un code d’authentification des messages à l’aide de la clé secrète fournie et le compare à la propriété MAC fournie
	VerifyContentPGP	Vérifie les signatures à l’aide des clés publiques OpenPGP

W¶

	Processeur	Description
	Wait	Route les FlowFiles entrants vers la relation « wait » jusqu’à ce qu’un signal de version correspondant soit stocké dans le cache distribué à partir d’un processeur Notify correspondant.
	WaitForTableState	Bloque les FlowFiles en entrée jusqu’à ce que l’état de la table correspondante diffère de l’état accepté.