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 |
|
---|---|---|
Snowflake |
Abandonne une requête dans Salesforce à l’aide de la fonction Bulk API 2. |
|
Génère une représentation CSV des attributs du FlowFile d’entrée. |
||
Génère une représentation JSON des attributs du FlowFile d’entrée. |
C¶
Processeur |
Description |
|
---|---|---|
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. |
||
Snowflake |
Lit les événements CDC à partir d’une base de données MySQL. |
|
Snowflake |
Lit les événements CDC à partir d’une base de données PostgreSQL. |
|
Snowflake |
Lit les événements CDC à partir d’une base de données SQL Server. |
|
Snowflake |
Capture les modifications apportées à un Google Drive partagé et émet un FlowFile pour chaque modification survenue. |
|
Snowflake |
Capture les changements survenant dans les groupes Microsoft365 et émet un FlowFile pour chaque changement qui se produit. |
|
Snowflake |
Capture les changements survenus dans une bibliothèque de documents Sharepoint et émet un FlowFile pour chacun d’entre eux. |
|
Snowflake |
Ce processeur vérifie si le rapport Meta Ads est prêt à être téléchargé. |
|
Snowflake |
Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères. |
|
Snowflake |
Découpe le texte en morceaux avec des options de division récursive par délimiteurs et par nombre maximal de caractères. |
|
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. |
||
Joue le rôle de point de terminaison de client WebSocket pour interagir avec un serveur WebSocket distant. |
||
Consomme les messages AMQP d’un courtier AMQP à l’aide de AMQP 0. |
||
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. |
||
Consomme les événements d’entreprise des flux Box de type admin_logs_streaming. |
||
Consomme tous les événements de Box. |
||
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. |
||
Consomme les messages de l’abonnement configuré à Google Cloud PubSub. |
||
Consomme les messages du serveur de messagerie en utilisant le protocole IMAP. |
||
Consomme un message JMS du type BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage, transforme son contenu en FlowFile et le transmet à la relation « success ». |
||
Consomme les messages de l’API Apache Kafka Consumer. |
||
Snowflake |
Consomme les messages de l’API Apache Kafka Consumer. |
|
Lit les données du flux AWS Kinesis 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 Record Reader et un Record Writer sont configurés. |
||
S’abonner à un sujet et recevoir des messages d’un broker MQTT |
||
Consomme les messages du serveur de messagerie en utilisant le protocole POP3. |
||
Récupère les messages d’un ou plusieurs canaux Slack configurés. |
||
Snowflake |
Récupère les messages des conversations Slack disponibles pour l’application. |
|
Snowflake |
Récupère l’historique des messages de tous les canaux Slack disponibles pour l’application. |
|
Snowflake |
Récupère les données d’un flux Snowflake et les écrit sur un FlowFile. |
|
Diffuse des tweets à partir de l’API de streaming version 2 de Twitter. |
||
Contrôle le débit auquel les données sont transférées aux processeurs suivants. |
||
Convertit le contenu d’un FlowFile d’un jeu de caractères à un autre |
||
Convertit les enregistrements d’un format de données à un autre à l’aide des Controller Services Record Reader et Record Writer configurés. |
||
Snowflake |
Convertit le schéma de la base de données entrante en un schéma approprié pour une table Snowflake CDC Journal. |
|
Copie un blob présent dans le stockage Azure Blob d’un compte/conteneur à un autre. |
||
Copie un fichier d’un compartiment et d’une clé vers un autre dans AWS S3 |
||
Calcule différentes métriques sur le texte entrant. |
||
Snowflake |
Processeur qui crée la configuration des rapports pour le connecteur Amazon Ads. |
|
Snowflake |
Utilise Azure OpenAI pour créer des intégrations pour le texte. |
|
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. |
||
Crée un modèle de métadonnées Box à l’aide des spécifications de champ provenant du contenu du FlowFile. |
||
Snowflake |
Utilise Cohere pour créer des intégrations pour le texte. |
|
Snowflake |
Processeur qui crée la configuration des rapports pour le connecteur Meta Ads. |
|
Snowflake |
Utilise OpenAI pour créer des intégrations pour le texte. |
|
Snowflake |
Créer des intégrations vectorielles à l’aide de fonctions Snowflake Cortex Large Language Model |
|
Snowflake |
Utilise VertexAI pour créer des intégrations pour le texte. |
|
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 |
|
---|---|---|
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. |
||
Déchiffre le contenu à l’aide de la spécification age-encryption. |
||
Déchiffrer le contenu de messages OpenPGP. |
||
Ce processeur dédouble les enregistrements individuels au sein d’un ensemble d’enregistrements. |
||
Supprime le blob spécifié d’Azure Blob Storage. |
||
Supprime le fichier fourni d’Azure Data Lake Storage |
||
Supprime une instance de métadonnées d’un fichier Box à l’aide de la clé de modèle spécifiée |
||
Effectuer une suppression d’un index Elasticsearch à l’aide d’une requête. |
||
Snowflake |
Supprimer des fichiers et répertoires DBFS. |
|
Supprime un document de DynamoDB en fonction d’une clé de hachage et d’intervalle. |
||
Supprime un fichier du système de fichiers. |
||
Supprime des objets d’un compartiment Google Cloud. |
||
Supprime un fichier de GridFS à l’aide d’un nom de fichier ou d’une requête. |
||
Snowflake |
Supprime des vecteurs de la base de données Milvus d’une collection par ID. |
|
Exécute une requête de suppression sur une collection MongoDB. |
||
Snowflake |
Supprime les vecteurs d’un index Pinecone. |
|
Snowflake |
Supprime une tâche de requête dans Salesforce à l’aide de la fonction Bulk API 2. |
|
Supprime un fichier d’un compartiment Amazon S3. |
||
Supprime un fichier résidant sur un serveur SFTP. |
||
Supprime un message d’une file d’attente Amazon Simple Queuing Service |
||
Snowflake |
Supprimez un fichier ou un répertoire du catalogue Unity. |
|
Snowflake |
Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud. |
|
Snowflake |
Décrire les métadonnées de l’objet spécifié dans Salesforce. |
|
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. |
||
Distribue les FlowFiles aux transformateurs en aval sur la base d’une stratégie de distribution. |
||
Destiné aux tests de charge, ce processeur créera le nombre configuré de copies de chaque FlowFile entrant. |
E¶
Processeur |
Description |
|
---|---|---|
Encodez ou décodez le contenu d’un FlowFile à l’aide des schémas d’encodage Base64, Base32 ou hexadécimal |
||
Chiffre le contenu à l’aide de la spécification age-encryption. |
||
Chiffrer le contenu à l’aide de OpenPGP. |
||
Renforce l’ordre attendu des FlowFiles qui appartiennent au même groupe de données au sein d’un même nœud. |
||
Snowflake |
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. |
|
Snowflake |
Enrichit les FlowFiles entrants qui proviennent de CaptureChangePostgreSQL, etc. |
|
Évalue une ou plusieurs expressions de JsonPath par rapport au contenu du FlowFile. |
||
Snowflake |
É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. |
|
Snowflake |
É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. |
|
Snowflake |
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. |
|
Évalue un ou plusieurs XPaths par rapport au contenu d’un FlowFile. |
||
Évalue un ou plusieurs XQueries par rapport au contenu d’un FlowFile. |
||
Processeur expérimental de scripts Groovy étendus. |
||
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. |
||
Expérimental - Exécute un script à partir d’un fichier de flux et d’une session de traitement. |
||
Exécute la requête SELECT fournie à SQL. |
||
Exécute la requête SELECT fournie à SQL. |
||
Snowflake |
Exécute une instruction SQL DDL ou DML sur une base de données. |
|
Le processeur ExecuteStreamCommand offre un moyen souple d’intégrer des commandes et des scripts externes dans les flux de données de NiFi. |
||
Extrait les métadonnées de l’en-tête d’un fichier de données Avro. |
||
Extrayez les pièces jointes d’un fichier e-mail au format mime, en les divisant en fichiers de flux individuels. |
||
En utilisant le contenu du fichier de flux comme source de données, extrayez l’en-tête d’un fichier de courrier électronique conforme à RFC en ajoutant les attributs pertinents au fichier de flux. |
||
É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 |
||
Extrait le schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et l’écrit dans l’attribut “avro. |
||
Snowflake |
Extrait les colonnes du schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et les écrit dans l’attribut ‘schema. |
|
Extrait les métadonnées d’un fichier Box à l’aide de Box AI. |
||
Évalue une ou plusieurs expressions régulières par rapport au contenu d’un FlowFile. |
F¶
Processeur |
Description |
|
---|---|---|
Récupère le blob spécifié dans Azure Blob Storage et écrit son contenu dans le contenu du FlowFile. |
||
Récupérer le fichier spécifié à partir du stockage Azure Data Lake |
||
Récupère les fichiers d’un dossier Box. |
||
Récupère les métadonnées des fichiers dans Box et les ajoute aux attributs du FlowFile. |
||
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. |
||
Extrait la représentation d’un fichier Box à l’aide d’un indice de représentation et l’écrit dans le contenu du FlowFile. |
||
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é. |
||
Récupère des fichiers dans Dropbox. |
||
Lit le contenu d’un fichier sur le disque et le transfère en flux dans le contenu d’un FlowFile entrant. |
||
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. |
||
Récupère un fichier à partir d’un compartiment de Google Cloud. |
||
Récupère des fichiers à partir d’un dossier Google Drive. |
||
Snowflake |
Récupère les commentaires et leurs réponses dans un fichier Google Drive. |
|
Snowflake |
Récupère les métadonnées des fichiers de Google Drive. |
|
Récupère un ou plusieurs fichiers d’un compartiment GridFS par nom de fichier ou par requête définie par l’utilisateur. |
||
Snowflake |
Récupère les problèmes dans Jira Cloud à l’aide de l’API REST v3 avec des options de recherche configurables. |
|
Snowflake |
Récupérer des enregistrements dans les tables Microsoft Dataverse |
|
Récupère le contenu d’un objet S3 et l’écrit dans le contenu d’un FlowFile |
||
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. |
||
Snowflake |
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. |
|
Snowflake |
Pour chaque lecteur, l’élément récupère ses métadonnées et ses autorisations et les écrit sous forme d’attributs FlowFile. |
|
Snowflake |
Récupère les infos des conversations Slack et les emails des membres |
|
Snowflake |
Télécharge un fichier partagé sur Slack. |
|
Snowflake |
Récupère les données relatives à un seul message Slack |
|
Récupère des fichiers à partir d’un partage SMB. |
||
Snowflake |
Lit les propriétés d’une table et les stocke en tant qu’attributs du FlowFile. |
|
Snowflake |
Récupère le schéma de la table (i. |
|
Snowflake |
Extrait un instantané d’une table d’une base de données. |
|
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. |
||
Snowflake |
Trouve un élément de Drive Sharepoint par son ID de lecteur et le chemin de l’élément. |
|
Donne à l’utilisateur la possibilité de prendre une documentation JSON imbriquée et de l’aplatir en un simple document de paires clé/valeur. |
||
Utilisé conjointement avec le processeur JoinEnrichment, ce processeur est chargé d’ajouter les attributs nécessaires à l’accomplissement de la fonction du processeur JoinEnrichment. |
||
Ce processeur permet à l’utilisateur de diviser un enregistrement en plusieurs enregistrements. |
G¶
Processeur |
Description |
|
---|---|---|
Snowflake |
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). |
|
Snowflake |
Génère des réponses synthétiques pour chaque question des enregistrements entrants à l’aide d’un LLM. |
|
Ce processeur crée des FlowFiles avec des données aléatoires ou un contenu personnalisé. |
||
Snowflake |
Produit un lot d’objets JSON avec des valeurs de champ aléatoires basées sur un schéma JSON configurable. |
|
Ce processeur crée des FlowFiles avec des enregistrements dont les valeurs des champs spécifiés sont aléatoires. |
||
Génère des requêtes SQL SELECT qui récupèrent des « pages » de lignes d’une table. |
||
Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile. |
||
Recherche les informations de géolocalisation pour une adresse IP et ajoute les informations de géolocalisation aux attributs FlowFile. |
||
Snowflake |
Le processeur télécharge le rapport des publicités Amazon s’il est prêt. |
|
Récupère le statut actuel d’une tâche AWS Polly. |
||
Récupère le statut actuel d’un travail AWS Textract. |
||
Récupère le statut actuel d’une tâche AWS Transcribe. |
||
Récupère le statut actuel d’une tâche AWS Translate. |
||
Reçoit des messages provenant de Microsoft Azure Event Hubs sans suivi fiable des points de contrôle. |
||
Récupère les messages à partir d’un stockage Azure Queue Storage. |
||
Récupère tous les collaborateurs d’un fichier Box et ajoute les informations de collaboration aux attributs de FlowFile. |
||
Récupère les membres d’un groupe Box et écrit leurs détails dans les attributs FlowFile. |
||
Snowflake |
Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud. |
|
Snowflake |
Décrivez les métadonnées de partage de données spécifiées dans Salesforce Data Cloud. |
|
Snowflake |
Lire un fichier DBFS. |
|
Récupère un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle. |
||
Processeur d’extraction Elasticsearch qui utilise les bibliothèques client officielles Elastic REST pour extraire un document unique d’Elasticsearch par _id. |
||
Crée FlowFiles à partir des fichiers d’un répertoire. |
||
Ce processeur crée des FlowFiles avec le contenu de la ressource fichier configurée. |
||
Récupère les fichiers d’un serveur FTP et crée les FlowFiles à partir de ces fichiers |
||
Récupère le statut actuel d’une opération Google Vision. |
||
Récupère le statut actuel d’une opération Google Vision. |
||
Snowflake |
Un processeur qui peut interagir avec Google Ads Reporting API. |
|
Snowflake |
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. |
|
Snowflake |
Processeur chargé d’extraire les données de Google Sheets. |
|
Récupère les données JSON à partir d’une application privée HubSpot. |
||
Snowflake |
Obtenir un objet HubSpot et ses associations par ID ou par valeur unique. |
|
Snowflake |
Le processeur télécharge des mesures à partir des APIs LinkedIn Reporting. |
|
Snowflake |
Récupère les membres du groupe Microsoft365 et émet un FlowFile pour chaque changement survenu. |
|
Crée des FlowFiles à partir de documents de MongoDB chargés par une requête spécifiée par l’utilisateur. |
||
Une version de GetMongo basée sur les enregistrements qui utilise les Record Writers pour écrire le jeu de résultats de MongoDB. |
||
Snowflake |
Obtient les résultats d’une requête dans Salesforce à l’aide de la fonction Bulk API 2. |
|
Snowflake |
Obtient le statut d’une requête dans Salesforce à l’aide de la fonction Bulk API 2. |
|
Vérifie l’existence d’un objet dans S3 et récupère ses métadonnées sans tenter de le télécharger. |
||
Vérifie l’existence d’un objet dans S3 et récupère ses balises sans tenter de le télécharger. |
||
Récupère les fichiers d’un serveur SFTP et crée les FlowFiles à partir de ces fichiers |
||
Snowflake |
Récupère tous les membres d’un groupe de sites SharePoint. |
|
Récupère les objets d’une boutique Shopify personnalisée. |
||
Lit un fichier à partir d’un emplacement du réseau samba sur des FlowFiles. |
||
Récupère les données de Splunk Enterprise. |
||
Récupère les messages d’une file d’attente Amazon Simple Queuing Service |
||
Snowflake |
Lit un fichier Unity Catalog jusqu’à 5 GiB. |
|
Snowflake |
Vérifie les métadonnées du fichier Unity Catalog. |
|
Un processeur qui peut interagir avec un rapport Workday configurable. |
||
Récupère de manière incrémentale les données de Zendesk API. |
H¶
Processeur |
Description |
|
---|---|---|
Démarre un serveur HTTP et écoute les requêtes HTTP. |
||
Envoie une réponse HTTP au demandeur qui a généré un FlowFile. |
I¶
Processeur |
Description |
|
---|---|---|
Tente d’identifier le type MIME utilisé pour un FlowFile. |
||
Un processeur client HTTP qui peut interagir avec un point de terminaison HTTP configurable. |
||
Expérimental - Invoque un moteur de script pour un processeur défini dans le script donné. |
||
Recherche les informations de ISP pour une adresse IP et ajoute les informations aux attributs de FlowFile. |
J¶
Processeur |
Description |
|
---|---|---|
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. |
||
Applique une liste de spécifications Jolt au contenu de FlowFile JSON, ou à un attribut spécifié de FlowFile JSON. |
||
Applique une spécification JOLT à chaque enregistrement de la charge utile FlowFile. |
||
Applique une transformation JSLT à la charge utile FlowFile JSON. |
||
Un processeur qui permet à l’utilisateur d’exécuter une requête (avec des agrégations) écrite avec Elasticsearch JSON DSL. |
L¶
Processeur |
Description |
|
---|---|---|
Snowflake |
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. |
|
Établit la liste des blobs dans un conteneur de stockage Azure Blob. |
||
Liste le répertoire dans un système de fichiers Azure Data Lake Storage Gen 2 |
||
Liste les fichiers d’un dossier Box. |
||
Récupère les métadonnées de chaque fichier d’un dossier Box. |
||
Récupère toutes les instances de métadonnées associées à un fichier Box. |
||
Récupère tous les modèles de métadonnées associés à un fichier Box. |
||
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. |
||
Snowflake |
Liste les noms de fichiers dans un répertoire DBFS et génère un nouveau FlowFile en sortie avec le nom du fichier. |
|
Récupère un listing de fichiers à partir de Dropbox (les raccourcis sont ignorés). |
||
Démarre un serveur FTP qui écoute sur le port spécifié et transforme les fichiers entrants en FlowFiles. |
||
Démarre un serveur HTTP et écoute sur un chemin de base donné pour transformer les requêtes entrantes en FlowFiles. |
||
Collecte les messages OpenTelemetry sur HTTP ou gRPC. |
||
Récupère les messages en temps réel ou les commandes Slack d’une ou plusieurs conversations Slack. |
||
Écoute des messages Syslog envoyés à un port donné via TCP ou UDP. |
||
É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. |
||
Écoute des paquets de datagrammes sur un port donné. |
||
Écoute les paquets de datagrammes sur un port donné et lit le contenu de chaque datagramme à l’aide du Record Reader configuré. |
||
Joue le rôle de point de terminaison du serveur WebSocket pour accepter les connexions client. |
||
Récupère une liste de fichiers dans le répertoire d’entrée. |
||
Effectue une liste des fichiers résidant sur un serveur FTP. |
||
Récupère une liste d’objets dans un compartiment GCS. |
||
Effectue une liste des fichiers concrets (les raccourcis sont ignorés) dans un dossier Google Drive. |
||
Snowflake |
Établit la liste de tous les fichiers et dossiers d’un Google Drive spécifié. |
|
Snowflake |
Répertorie tous les groupes d’un domaine donné dans Google Workspace. |
|
Snowflake |
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. |
|
Snowflake |
Tables de liste des environnements Microsoft Dataverse |
|
Récupère une liste d’objets à partir d’un compartiment S3. |
||
Snowflake |
Dresse la liste des partages de données disponibles dans l’organisation et accessibles à l’utilisateur identifié. |
|
Snowflake |
Liste des objets disponibles dans l’organisation et accessibles à l’utilisateur identifié. |
|
Effectue une liste des fichiers résidant sur un serveur SFTP. |
||
Snowflake |
Émet un FlowFile pour chaque lecteur présent dans le site Sharepoint spécifié. |
|
Snowflake |
Liste tous les groupes de sites SharePoint disponibles sur un site SharePoint spécifié. |
|
Liste des fichiers concrets partagés via le protocole SMB. |
||
Snowflake |
Récupère tous les noms de table source et les met en correspondance avec l’une des configurations possibles :- regexp expression e. |
|
Snowflake |
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. |
|
Émet les attributs de FlowFile au niveau de journalisation spécifié |
||
Émet un message de journalisation au niveau de journalisation spécifié |
||
Recherche d’attributs à partir d’un service de consultation |
||
Extrait un ou plusieurs champs d’un enregistrement et recherche une valeur pour ces champs dans LookupService. |
M¶
Processeur |
Description |
|
---|---|---|
Fusionne un groupe de FlowFiles sur la base d’une stratégie définie par l’utilisateur et les regroupe en un seul FlowFile. |
||
Ce processeur fusionne plusieurs enregistrements FlowFiles en un seul FlowFile qui contient tous les enregistrements du FlowFiles en entrée. |
||
Snowflake |
Déclenche une opération de fusion sur les modifications de la table du journal vers une table de destination dans Snowflake. |
|
Rejette une plage d’octets au début et à la fin ou tout le contenu d’un fichier binaire. |
||
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. |
||
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 |
||
Déplace le contenu au sein d’un Azure Data Lake Storage Gen 2. |
N¶
Processeur |
Description |
|
---|---|---|
Met en cache un identificateur de signal de version dans le cache distribué, éventuellement avec les attributs du FlowFile. |
O¶
Processeur |
Description |
|
---|---|---|
Snowflake |
Procède à la transcription du son en texte anglais. |
P¶
Processeur |
Description |
|
---|---|---|
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. |
||
Un processeur qui permet à l’utilisateur d’exécuter une requête paginée (avec agrégations) écrite avec Elasticsearch JSON DSL. |
||
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 |
||
Snowflake |
Processeur responsable de l’analyse des formules de référence des cellules Excel. |
|
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. |
||
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. |
||
Fractionne, ou partitionne, les données orientées enregistrement en fonction des champs configurés dans les données. |
||
Snowflake |
Effectue la reconnaissance optique des caractères (OCR) sur les documents PDF en utilisant les fonctions ML du Snowflake Cortex. |
|
Snowflake |
Accepte une liste de noms de tables entièrement 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 périmée (est répliquée mais n’existe plus dans la source) La configuration est transmise en tant qu’attribut de FlowFile. |
|
Snowflake |
Envoie une invite à Anthropic, en écrivant la réponse sous forme d’attribut FlowFile ou dans le contenu du FlowFile entrant. |
|
Snowflake |
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. |
|
Snowflake |
Ce processeur envoie une invite définie par l’utilisateur à un Large Language Model (LLM) pour qu’il y réponde. |
|
Snowflake |
Envoie une invite à OpenAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant. |
|
Snowflake |
Envoie une demande à Snowflake Cortex, en écrivant la réponse sous la forme d’un attribut FlowFile ou dans le contenu du FlowFile entrant. |
|
Snowflake |
Envoie une invite à VertexAI, en écrivant la réponse sous forme d’attribut de FlowFile ou dans le contenu du FlowFile entrant. |
|
Crée un message AMQP à partir du contenu d’un FlowFile et envoie le message à un échange AMQP. |
||
Publie le contenu du FlowFile entrant dans la rubrique configurée de Google Cloud PubSub. |
||
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. |
||
Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API. |
||
Snowflake |
Envoie le contenu d’un FlowFile sous forme de message ou d’enregistrements individuels à Apache Kafka à l’aide de Kafka Producer API. |
|
Publie un message sur un sujet MQTT |
||
Publie un message sur le canal Slack spécifié. |
||
Place le contenu dans un blob sur Azure Blob Storage. |
||
Ce processeur est un processeur d’enregistrement pour l’insertion de données dans Cosmos DB avec Core SQL API. |
||
Agit comme un puits Azure Data Explorer qui envoie des FlowFiles au point de terminaison fourni. |
||
Écrit le contenu d’un FlowFile en tant que fichier sur Azure Data Lake Storage Gen 2 |
||
Envoie le contenu de FlowFile sur Azure Event Hubs |
||
Écrit le contenu des FlowFiles entrants dans le stockage Azure Queue Sorage configuré. |
||
Écrit le contenu d’un FlowFile dans une table Google BigQuery. |
||
Place le contenu dans un dossier Box. |
||
Publie les métriques sur Amazon CloudWatch. |
||
Le processeur PutDatabaseRecord utilise un RecordReader spécifié pour utiliser en entrée des enregistrements (éventuellement multiples) à partir d’un FlowFile entrant. |
||
Snowflake |
Soumet une exécution SQL à l’aide de Databricks REST API puis écrit la réponse JSON dans le contenu du FlowFile. |
|
Snowflake |
Rédige le contenu de FlowFile sur DBFS. |
|
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. |
||
Place le contenu dans un dossier Dropbox. |
||
Place un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle. |
||
Insère des éléments dans DynamoDB sur la base de données orientées enregistrement. |
||
Un processeur de mise en place d’Elasticsearch qui utilise les bibliothèques client officielles d’Elastic REST. |
||
Un processeur de mise en place d’Elasticsearch tenant compte des enregistrements et utilisant les bibliothèques client officielles d’Elastic REST. |
||
Envoi d’un courrier électronique aux destinataires configurés pour chaque FlowFile entrant |
||
Écrit le contenu d’un FlowFile dans le système de fichiers local |
||
Envoie des FlowFiles à un serveur FTP |
||
Écrit le contenu d’un FlowFile en tant qu’objet dans un Google Cloud Storage. |
||
Rédige le contenu d’un FlowFile sous forme de fichier dans Google Drive. |
||
Écrit un fichier dans un compartiment GridFS. |
||
Snowflake |
Insertion d’un objet HubSpot. |
|
Snowflake |
Stocke les enregistrements dans Iceberg à l’aide d’un catalogue configurable pour la gestion des espaces de noms et des tables. |
|
Envoie le contenu vers un Amazon Kinesis Firehose spécifié. |
||
Envoie le contenu à un Amazon Kinesis spécifié. |
||
Envoie le contenu à une fonction Amazon Lambda spécifiée. |
||
Écrit le contenu d’un FlowFile sur MongoDB |
||
Écrit le contenu d’un FlowFile sur MongoDB en tant que bulk-update |
||
Ce processeur est un processeur d’enregistrement pour l’insertion/la réinsertion de données dans MongoDB. |
||
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. |
||
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. |
||
Écrit le contenu d’un FlowFile en tant qu’objet S3 dans un compartiment Amazon S3 Bucket. |
||
Crée de nouveaux enregistrements pour l’objet Salesforce sObject spécifié. |
||
Envoie des FlowFiles à un serveur SFTP |
||
Écrit le contenu d’un FlowFile à un emplacement du réseau samba. |
||
Snowflake |
Place les fichiers dans une zone de préparation interne de Snowflake. |
|
Snowflake |
Diffuse les enregistrements dans une table Snowflake. |
|
Envoie le contenu d’un FlowFile sous forme de notification à Amazon Simple Notification Service |
||
Envoie les journaux à Splunk Enterprise via TCP, TCP + TLS/SSL, ou UDP. |
||
Envoie le contenu du FlowFile au serveur Splunk spécifié via HTTP ou HTTPS. |
||
Exécute une commande SQL UPDATE ou INSERT. |
||
Publie un message dans une file d’attente d’Amazon Simple Queuing Service |
||
Envoie des messages Syslog à un hôte et à un port donnés via TCP ou UDP. |
||
Envoi de FlowFiles ou d’enregistrements sérialisés sur TCP vers une destination configurable avec prise en charge optionnelle de TLS |
||
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é. |
||
Snowflake |
Rédige le contenu de FlowFile avec une taille maximale de 5 GiB pour Unity Catalog. |
|
Snowflake |
Génère et télécharge une documentation JSON vers le point de terminaison de Vectara. |
|
Snowflake |
Télécharge un contenu FlowFile sur l’index du point de terminaison de Vectara. |
|
Envoi de messages à un point de terminaison distant WebSocket à l’aide d’une session WebSocket établie par ListenWebSocket ou ConnectWebSocket. |
||
Crée des tickets Zendesk à l’aide de Zendesk API. |
Q¶
Processeur |
Description |
|
---|---|---|
Interroge Azure Data Explorer et diffuse les résultats JSON vers les FlowFiles en sortie |
||
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. |
||
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. |
||
Snowflake |
Effectue la requête d’une collection donnée dans une base de données Milvus à l’aide de vecteurs. |
|
Snowflake |
Interroge Pinecone sur les vecteurs similaires au vecteur d’entrée, ou récupère un vecteur par ID. |
|
Évalue une ou plusieurs requêtes SQL par rapport au contenu d’un FlowFile. |
||
Récupère les enregistrements d’un objet Salesforce sObject. |
||
Interroge le serveur Splunk afin d’obtenir le statut de l’accusé de réception de l’indexation. |
R¶
Processeur |
Description |
|
---|---|---|
Modifie le contenu d’un FlowFile qui contient des données orientées enregistrement (i. |
||
Renomme un ou plusieurs champs dans chaque enregistrement d’un FlowFile. |
||
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. |
||
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. |
||
Les FlowFiles transmis à ce processeur ont une valeur « Retry Attribute » vérifiée par rapport à une valeur « « Maximum Retries » configurée. |
||
Route lesattribut FlowFiles en fonction de leurs attributs à l’aide de Attribute Expression Language |
||
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. |
||
Route des données textuelles sur la base d’un ensemble de règles définies par l’utilisateur. |
||
Snowflake |
Déclenche l’exécution d’un travail Databricks prédéfini avec des paramètres personnalisés. |
|
Un processeur qui exécute une requête d’agrégation chaque fois qu’il reçoit un FlowFile. |
S¶
Processeur |
Description |
|
---|---|---|
É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). |
||
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é |
||
Recherche dans le contenu de FlowFiles les termes qui se trouvent dans un dictionnaire fourni par l’utilisateur. |
||
Ce processeur offre la possibilité de filtrer les enregistrements à partir de FlowFiles à l’aide du script fourni par l’utilisateur. |
||
Reçoit des données orientées enregistrement (i. |
||
Fournit la possibilité d’évaluer un script simple pour chaque enregistrement d’un FlowFile entrant. |
||
Ce processeur offre la possibilité de valider les enregistrements dans les FlowFiles à l’aide du script fourni par l’utilisateur. |
||
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. |
||
Segmente un FlowFile en plusieurs segments plus petits dans la limite des octets. |
||
Signe le contenu à l’aide des clés privées de OpenPGP |
||
Snowflake |
Vérifie si le hachage d’un FlowFile(fourni comme attribut FlowFile) se trouve déjà dans une table Snowflake, et route le FlowFile vers « duplicate » s’il est trouvé, « distinct » s’il n’est pas trouvé, ou « failure » en cas d’erreur. |
|
Divise un fichier de données Avro codé en binaire en plusieurs fichiers plus petits en fonction de la taille de sortie configurée. |
||
Fractionne les FlowFiles entrants en fonction d’une séquence d’octets spécifiée |
||
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. |
||
Fractionne un fichier JSON en plusieurs FlowFiles distincts pour un élément de tableau spécifié par une expression JsonPath. |
||
Fractionne unFlowFile en entrée au format de données orienté enregistrement en plusieurs FlowFiles plus petits |
||
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. |
||
Fractionne un fichier XML en plusieurs FlowFiles distincts, chacun comprenant un enfant ou un descendant de l’élément racine d’origine |
||
Déclenche une tâche AWS Polly. |
||
Déclenche une tâche AWS Textract. |
||
Déclenche une tâche AWS Transcribe. |
||
Déclenche une tâche AWS Translate. |
||
Déclenche une opération Vision sur un fichier en entrée. |
||
Déclenche une opération Vision sur une image en entrée. |
||
Snowflake |
Soumet une requête à Salesforce à l’aide de la fonction Bulk API 2. |
|
Snowflake |
Ce processeur utilise un Large Language Model (LLM) pour résumer le contenu d’un FlowFile. |
T¶
Processeur |
Description |
|
---|---|---|
Ajoute ou met à jour une balise sur un objet Amazon S3. |
||
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. |
||
Applique le fichier XSLT fourni à la charge utile XML du FlowFile. |
U¶
Processeur |
Description |
|
---|---|---|
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. |
||
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 |
||
Met à jour les valeurs du modèle de métadonnées pour un fichier Box en utilisant l’enregistrement dans le FlowFile donné. |
||
Met à jour les documents d’un index Elasticsearch à l’aide d’une requête. |
||
Ce processeur permet aux utilisateurs de définir des paramètres spécifiques et des points clés dans leur flux. |
||
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. |
||
Met à jour le contenu d’un FlowFile qui contient des données orientées enregistrement (i. |
||
Snowflake |
Met à jour la définition d’une table Snowflake sur la base du schéma fourni dans le FlowFile entrant. |
|
Snowflake |
Met à jour la définition d’une table Snowflake Iceberg. |
|
Snowflake |
Met à jour l’état d’une table dans le service d’état des tables |
|
Snowflake |
Insère les vecteurs dans la base de données Milvus pour une collection donnée |
|
Snowflake |
Publie les vecteurs, y compris les métadonnées, et éventuellement le texte, dans un index Pinecone. |
|
Snowflake |
Insère via Upsert les enregistrements provenant du FlowFile dans Salesforce |
V¶
Processeur |
Description |
|
---|---|---|
Valide le contenu des FlowFiles ou une valeur d’attribut de FlowFile par rapport à un schéma CSV spécifié par l’utilisateur. |
||
Valide le contenu des FlowFiles par rapport à un schéma JSON configurable. |
||
Valide les enregistrements d’un FlowFile entrant par rapport à un schéma donné. |
||
Valide le contenu XML dans un FlowFile. |
||
Calcule un code d’authentification des messages à l’aide de la clé secrète fournie et le compare à la propriété MAC fournie |
||
Vérifie les signatures à l’aide des clés publiques OpenPGP |
W¶
Processeur |
Description |
|
---|---|---|
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. |
||
Snowflake |
Bloque les FlowFiles en entrée jusqu’à ce que l’état de la table correspondante diffère de l’état accepté. |