Tous les contrôleurs (par ordre alphabétique)¶
Cette rubrique fournit une liste de tous les contrôleurs de débit par ordre alphabétique. La liste comprend :
Type de contrôleur (Snowflake ou non)
Le nom de chaque contrôleur
Un résumé de chaque contrôleur
A¶
Contrôleur |
Description |
|
---|---|---|
Définit les identifiants de connexion pour les processeurs ADLS. |
||
Fournit un ADLSCredentialsService qui peut être utilisé pour sélectionner dynamiquement un autre ADLSCredentialsService. |
||
Fournit un registre de schémas qui interagit avec le registre de schémas Glue de AWS afin que les schémas stockés dans le registre de schémas Glue puissent être utilisés dans NiFi. |
||
Fournit et gère les connexions à AWS MSK Kafka Brokers pour les opérations de producteurs ou de consommateurs. |
||
Snowflake |
Fournit et gère les connexions à AWS MSK Kafka Brokers pour les opérations de producteurs ou de consommateurs. |
|
Fournit un registre de schémas qui interagit avec le registre de schémas d’Apicurio afin que les schémas stockés dans le registre de schémas d’Apicurio puissent être utilisés dans NiFi. |
||
Analyse les données Avro et renvoie chaque enregistrement Avro sous la forme d’un objet Record distinct. |
||
Écrit le contenu d’un site RecordSet au format binaire Avro. |
||
Fournit un service pour l’enregistrement et l’accès aux schémas. |
||
Définit les identifiants de connexion des processeurs Amazon Web Services. |
||
Fournit une ressource de fichier Azure Blob Storage pour d’autres composants. |
||
Fournit un service de contrôle qui configure une connexion à Cosmos DB (APISQL Core) et fournit un accès à cette connexion à d’autres composants liés à Cosmos DB. |
||
Fournit une ressource de fichier Azure Data Lake Storage (ADLS) pour les autres composants. |
||
Formater et envoyer des enregistrements à Azure Event Hubs |
||
Fournit les identifiants des fournisseurs de stockage Azure utilisant la bibliothèque client Azure Storage v12. |
||
Fournit un AzureStorageCredentialsService_v12 qui peut être utilisé pour sélectionner dynamiquement un autre AzureStorageCredentialsService_v12. |
C¶
Contrôleur |
Description |
|
---|---|---|
Analyse les événements CEF (Common Event Format) et renvoie chaque ligne sous la forme d’un enregistrement. |
||
Lit l’identificateur de schéma selon l’encodage Confluent sous la forme d’un en-tête composé d’un marqueur d’octet et d’un entier représenté sur quatre octets |
||
Écrit l’identificateur de schéma selon l’encodage Confluent sous la forme d’un en-tête composé d’un marqueur d’octet et d’un entier représenté sur quatre octets |
||
Fournit un registre de schémas qui interagit avec le registre de schémas de Confluent afin que les schémas stockés dans le registre de schémas de Confluent puissent être utilisés dans NiFi. |
||
Analyse les données au format CSV et renvoie chaque ligne du fichier CSV sous la forme d’un enregistrement distinct. |
||
Un service de recherche basé sur le fichier CSV rechargeable. |
||
Écrit le contenu d’un site RecordSet en tant que données CSV. |
D¶
Contrôleur |
Description |
|
---|---|---|
Snowflake |
Un service de consultation qui permet d’enrichir une base de données à l’aide d’une instruction SQL spécifiée par l’utilisateur. |
|
Un service de recherche basé sur une base de données relationnelle. |
||
Fournit un service permettant d’écrire des enregistrements à l’aide d’une connexion de base de données configurée. |
||
Fournit le service de pooling de connexions à la base de données. |
||
Fournit un DBCPService qui peut être utilisé pour sélectionner dynamiquement un autre DBCPService. |
||
Fournit des objets client Box par lesquels les appels d’API Box peuvent être utilisés. |
||
Permet de choisir un client de cache de mappage distribué pour récupérer la valeur associée à une clé. |
E¶
Contrôleur |
Description |
|
---|---|---|
Un service de contrôleur pour l’accès à un client Elasticsearch, en utilisant le client REST Elasticsearch (de bas niveau). |
||
Recherche d’un enregistrement du serveur Elasticsearch associé à l’ID de document spécifié. |
||
Recherche d’une valeur de chaîne dans le serveur Elasticsearch associée à l’ID de document spécifié. |
||
Fournit un RecordSinkService qui peut être utilisé pour envoyer des enregistrements par courrier électronique en utilisant le rédacteur spécifié pour le formatage. |
||
Un service qui exécute Hazelcast intégré et fournit des instances de cache soutenues par ce dernier. |
||
Analyse un document Microsoft Excel en renvoyant chaque ligne de chaque feuille comme un enregistrement distinct. |
||
Un service qui fournit des instances de cache soutenues par Hazelcast fonctionnant en dehors de NiFi. |
F¶
Contrôleur |
Description |
|
---|---|---|
Écrit le contenu d’un site RecordSet sous forme de texte libre. |
G¶
Contrôleur |
Description |
|
---|---|---|
Définit les identifiants pour les processeurs de Google Cloud Platform. |
||
Fournit une ressource de fichier Google Compute Storage (GCS) pour d’autres composants. |
||
Fournit un mécanisme permettant de lire des données textuelles non structurées, telles que des fichiers de connexion, et de structurer les données afin qu’elles puissent être traitées. |
H¶
Contrôleur |
Description |
|
---|---|---|
Une implémentation de DistributedMapCacheClient qui utilise Hazelcast comme cache de sauvegarde. |
||
Fournit un service de pooling de connexions de bases de données basé sur HikariCP. |
||
Formatez et envoyez des enregistrements à une uri configurée à l’aide d’une publication HTTP. |
I¶
Contrôleur |
Description |
|
---|---|---|
Un service de recherche qui fournit plusieurs types d’informations d’enrichissement pour les adresses IP. |
J¶
Contrôleur |
Description |
|
---|---|---|
Mise en œuvre de WebSocketClientService. |
||
Mise en œuvre de WebSocketServerService. |
||
Fournit un service générique pour créer des fichiers javax. |
||
Fournit un service permettant de consulter un JMS ConnectionFactory existant à l’aide de l’interface Java de nommage et de répertoire (JNDI). |
||
Fournit des objets client Box par lesquels les appels d’API Box peuvent être utilisés. |
||
Analyse les enregistrements JSON et évalue les chemins JSON définis par l’utilisateur par rapport à chaque objet JSON. |
||
Écrit les résultats de RecordSet sous la forme d’un tableau JSON ou d’un objet JSON par ligne. |
||
Snowflake |
Fournit un filtre de colonne de table basé sur une configuration JSON. |
|
Analyse JSON en objets d’enregistrement individuels. |
||
Fournit 2 OAuth. |
K¶
Contrôleur |
Description |
|
---|---|---|
Fournit et gère les connexions aux Brokers Kafka pour les opérations de producteurs ou de consommateurs. |
||
Snowflake |
Fournit et gère les connexions aux Brokers Kafka pour les opérations de producteurs ou de consommateurs. |
L¶
Contrôleur |
Description |
|
---|---|---|
Fournit un RecordSinkService qui peut être utilisé pour connecter des enregistrements au journal de l’application (nifi-app. |
M¶
Contrôleur |
Description |
|
---|---|---|
Fournit la possibilité de communiquer avec un MapCacheServer. |
||
Fournit un cache de carte (clé/valeur) accessible via une socket. |
||
Snowflake |
Fournit des jetons d’accès OAuth2 pour l’API Microsoft Graph en utilisant client_credentials avec un certificat client. |
|
Snowflake |
Fournit l’authentification pour l’API Microsoft Graph, qui peut être utilisée pour interagir avec les services Microsoft 365. |
|
Fournit un service contrôleur qui configure une connexion à MongoDB et fournit l’accès à cette connexion à d’autres composants liés à Mongo. |
||
Fournit un service de recherche basé sur MongoDB. |
P¶
Contrôleur |
Description |
|
---|---|---|
Snowflake |
Fournit la sérialisation des enregistrements pour Apache Iceberg en utilisant le formatage d’Apache Parquet |
|
SSLContext Le fournisseur peut être configuré à l’aide des fichiers de clé privée et de certificat de PEM. |
||
Snowflake |
Fournit l’intégration d’Apache Iceberg avec l’accès au catalogue d’Apache Polaris par l’intermédiaire de REST HTTP |
|
Un service de recherche basé sur un fichier de propriétés rechargeable |
R¶
Contrôleur |
Description |
|
---|---|---|
Fournit un RecordReaderFactory qui peut être utilisé pour sélectionner dynamiquement un autre RecordReaderFactory. |
||
Fournit un RecordSetWriterFactory qui peut être utilisé pour sélectionner dynamiquement un autre RecordSetWriterFactory. |
||
Fournit un RecordSinkService qui peut être utilisé pour sélectionner dynamiquement un autre RecordSinkService. |
||
Un service qui fournit des connexions à Redis. |
||
Une implémentation de DistributedMapCacheClient qui utilise Redis comme cache de sauvegarde. |
||
Utilisez un service REST pour rechercher des valeurs. |
S¶
Contrôleur |
Description |
|
---|---|---|
Fournit une ressource de fichier S3 d’Amazon Web Services (AWS) pour d’autres composants. |
||
Snowflake |
Récupère un jeton d’accès OAuth2 de Salesforce à l’aide du fournisseur de jeton d’accès OAuth2 configuré et échange le jeton contre un jeton d’API de Data Cloud. |
|
Permet à l’utilisateur de fournir une instance LookupService scriptée afin d’enrichir les enregistrements d’un fichier de flux entrant. |
||
Permet à l’utilisateur de fournir une instance RecordReaderFactory scriptée afin de lire/parser/générer des enregistrements à partir d’un fichier de flux entrant. |
||
Permet à l’utilisateur de fournir une instance RecordSetWriterFactory scriptée afin d’écrire des enregistrements dans un fichier de flux sortant. |
||
Permet à l’utilisateur de fournir une instance RecordSinkService scriptée afin de transmettre des enregistrements à la cible souhaitée. |
||
Fournit la possibilité de communiquer avec un SetCacheServer. |
||
Fournit un cache d’ensemble (collection de valeurs uniques) auquel on peut accéder par l’intermédiaire d’une socket. |
||
Un service de recherche basé sur le fichier CSV rechargeable. |
||
Un service de recherche basé sur une base de données relationnelle. |
||
Permet aux utilisateurs d’ajouter des paires clé/valeur en tant que propriétés définies par l’utilisateur. |
||
Une implémentation de DistributedMapCacheClient qui utilise Redis comme cache de sauvegarde. |
||
Permet à l’utilisateur de fournir une instance LookupService scriptée afin d’enrichir les enregistrements d’un fichier de flux entrant. |
||
Formatez et envoyez des enregistrements à un canal configuré à l’aide de l’API Slack Post Message. |
||
Permet l’accès aux sessions SMB avec des identifiants d’authentification partagés. |
||
Snowflake |
Fournit des connexions de bases de données poolées aux services Snowflake |
|
Snowflake |
Database Dialect Service supportant Snowflake. |
|
Snowflake |
||
Snowflake |
||
Snowflake |
Un Controller Service qui fournit une intégration avec les modèles Claude AI d’Anthropic par le biais de leurs API de messages. |
|
Fournissez les identifiants à utiliser avec un client Azure. |
||
Snowflake |
Client Databricks. |
|
Définit les identifiants de connexion pour les processeurs Dropbox. |
||
Fournit une ressource de fichier pour d’autres composants. |
||
Un service de contrôleur pour interagir avec HashiCorp Vault. |
||
Offre la possibilité de stocker et de récupérer les requêtes et les réponses HTTP en dehors d’un fournisseur, de sorte que plusieurs fournisseurs puissent interagir avec la même requête HTTP. |
||
Snowflake |
HubSpot Controller Service pour l’intégration avec l’api HubSpot HTTP. |
|
Fournit un service pour l’enregistrement et l’accès aux schémas JSON. |
||
Envoie des lots de contenus de fichiers de flux ou des flux de contenus de fichiers de flux à un cluster Azure ADX. |
||
Mise en œuvre standard du service de requête Kusto pour Azure Data Explorer |
||
Snowflake |
Fournit un service de connexion à une instance Milvus |
|
Fournit 2 OAuth. |
||
Snowflake |
Fournit une intégration au service Openflow OCR |
|
Snowflake |
Un Controller Service qui assure l’intégration avec l’API Chat Completion d’OpenAI. |
|
Le service de clé privée PGP fournit des clés privées chargées à partir de fichiers ou de propriétés |
||
Service de clés publiques PGP fournissant des clés publiques chargées à partir de fichiers |
||
Le service de clé privée permet d’accéder à une clé privée chargée à partir de sources configurées |
||
Fournit un ensemble de configurations pour différents composants de NiFi afin d’utiliser un serveur proxy. |
||
Mise en œuvre restreinte du site SSLContextService. |
||
Ajoute un chiffrement configurable aux opérations S3 Put et S3 Fetch. |
||
Snowflake |
Fournit un service de connexion aux APIs Salesforce |
|
Snowflake |
Fournit un service de connexion aux APIs Salesforce Data Cloud |
|
Mise en œuvre standard du site SSLContextService. |
||
Snowflake |
Un service de contrôleur qui fournit et gère l’état de la table. |
|
Snowflake |
Vectara Controller Service pour l’intégration avec Vectara HTTP Api. |
|
Fournisseur de services pour le client Web avec prise en charge de la configuration des propriétés de connexion standard de HTTP |
||
Snowflake |
Utilise la gestion d’état intégrée NiFi pour stocker les hachages des schémas de table. |
|
Fournit un mécanisme pour lire les données Syslog conformes à RFC 5424, telles que les fichiers journaux, et pour structurer les données afin qu’elles puissent être traitées. |
||
Tente d’analyser le contenu d’un message Syslog conformément à RFC5424 et RFC3164. |
U¶
Contrôleur |
Description |
|
---|---|---|
Formatage et envoi des enregistrements sous forme de paquets de datagrammes UDP vers une destination configurable |
V¶
Contrôleur |
Description |
|
---|---|---|
Fournit un cache de schéma qui évacue les éléments sur la base d’un algorithme de moindre utilisation. |
W¶
Contrôleur |
Description |
|
---|---|---|
Lit les données du journal des événements de Windows en tant que contenu de XML ayant été généré par ConsumeWindowsEventLog, ParseEvtx, etc. |
X¶
Contrôleur |
Description |
|
---|---|---|
Un service de recherche basé sur le fichier XML rechargeable. |
||
Lit le contenu de XML et crée des objets d’enregistrement. |
||
Écrit une page RecordSet sur XML. |
Y¶
Contrôleur |
Description |
|
---|---|---|
Analyse YAML en objets d’enregistrement individuels. |