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

ADLSCredentialsControllerService

Définit les identifiants de connexion pour les processeurs ADLS.

ADLSCredentialsControllerServiceLookup

Fournit un ADLSCredentialsService qui peut être utilisé pour sélectionner dynamiquement un autre ADLSCredentialsService.

AmazonGlueSchemaRegistry

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.

AmazonMSKConnectionService

Fournit et gère les connexions à AWS MSK Kafka Brokers pour les opérations de producteurs ou de consommateurs.

Snowflake

AmazonMSKConnectionService

Fournit et gère les connexions à AWS MSK Kafka Brokers pour les opérations de producteurs ou de consommateurs.

ApicurioSchemaRegistry

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.

AvroReader

Analyse les données Avro et renvoie chaque enregistrement Avro sous la forme d’un objet Record distinct.

AvroRecordSetWriter

Écrit le contenu d’un site RecordSet au format binaire Avro.

AvroSchemaRegistry

Fournit un service pour l’enregistrement et l’accès aux schémas.

AWSCredentialsProviderControllerService

Définit les identifiants de connexion des processeurs Amazon Web Services.

AzureBlobStorageFileResourceService

Fournit une ressource de fichier Azure Blob Storage pour d’autres composants.

AzureCosmosDBClientService

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.

AzureDataLakeStorageFileResourceService

Fournit une ressource de fichier Azure Data Lake Storage (ADLS) pour les autres composants.

AzureEventHubRecordSink

Formater et envoyer des enregistrements à Azure Event Hubs

AzureStorageCredentialsControllerService_v12

Fournit les identifiants des fournisseurs de stockage Azure utilisant la bibliothèque client Azure Storage v12.

AzureStorageCredentialsControllerServiceLookup_v12

Fournit un AzureStorageCredentialsService_v12 qui peut être utilisé pour sélectionner dynamiquement un autre AzureStorageCredentialsService_v12.

C

Contrôleur

Description

CEFReader

Analyse les événements CEF (Common Event Format) et renvoie chaque ligne sous la forme d’un enregistrement.

ConfluentEncodedSchemaReferenceReader

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

ConfluentEncodedSchemaReferenceWriter

É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

ConfluentSchemaRegistry

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.

CSVReader

Analyse les données au format CSV et renvoie chaque ligne du fichier CSV sous la forme d’un enregistrement distinct.

CSVRecordLookupService

Un service de recherche basé sur le fichier CSV rechargeable.

CSVRecordSetWriter

Écrit le contenu d’un site RecordSet en tant que données CSV.

D

Contrôleur

Description

Snowflake

DatabaseLookup

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.

DatabaseRecordLookupService

Un service de recherche basé sur une base de données relationnelle.

DatabaseRecordSink

Fournit un service permettant d’écrire des enregistrements à l’aide d’une connexion de base de données configurée.

DBCPConnectionPool

Fournit le service de pooling de connexions à la base de données.

DBCPConnectionPoolLookup

Fournit un DBCPService qui peut être utilisé pour sélectionner dynamiquement un autre DBCPService.

DeveloperBoxClientService

Fournit des objets client Box par lesquels les appels d’API Box peuvent être utilisés.

DistributedMapCacheLookupService

Permet de choisir un client de cache de mappage distribué pour récupérer la valeur associée à une clé.

E

Contrôleur

Description

ElasticSearchClientServiceImpl

Un service de contrôleur pour l’accès à un client Elasticsearch, en utilisant le client REST Elasticsearch (de bas niveau).

ElasticSearchLookupService

Recherche d’un enregistrement du serveur Elasticsearch associé à l’ID de document spécifié.

ElasticSearchStringLookupService

Recherche d’une valeur de chaîne dans le serveur Elasticsearch associée à l’ID de document spécifié.

EmailRecordSink

Fournit un RecordSinkService qui peut être utilisé pour envoyer des enregistrements par courrier électronique en utilisant le rédacteur spécifié pour le formatage.

EmbeddedHazelcastCacheManager

Un service qui exécute Hazelcast intégré et fournit des instances de cache soutenues par ce dernier.

ExcelReader

Analyse un document Microsoft Excel en renvoyant chaque ligne de chaque feuille comme un enregistrement distinct.

ExternalHazelcastCacheManager

Un service qui fournit des instances de cache soutenues par Hazelcast fonctionnant en dehors de NiFi.

F

Contrôleur

Description

FreeFormTextRecordSetWriter

Écrit le contenu d’un site RecordSet sous forme de texte libre.

G

Contrôleur

Description

GCPCredentialsControllerService

Définit les identifiants pour les processeurs de Google Cloud Platform.

GCSFileResourceService

Fournit une ressource de fichier Google Compute Storage (GCS) pour d’autres composants.

GrokReader

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

HazelcastMapCacheClient

Une implémentation de DistributedMapCacheClient qui utilise Hazelcast comme cache de sauvegarde.

HikariCPConnectionPool

Fournit un service de pooling de connexions de bases de données basé sur HikariCP.

HttpRecordSink

Formatez et envoyez des enregistrements à une uri configurée à l’aide d’une publication HTTP.

I

Contrôleur

Description

IPLookupService

Un service de recherche qui fournit plusieurs types d’informations d’enrichissement pour les adresses IP.

J

Contrôleur

Description

JettyWebSocketClient

Mise en œuvre de WebSocketClientService.

JettyWebSocketServer

Mise en œuvre de WebSocketServerService.

JMSConnectionFactoryProvider

Fournit un service générique pour créer des fichiers javax.

JndiJmsConnectionFactoryProvider

Fournit un service permettant de consulter un JMS ConnectionFactory existant à l’aide de l’interface Java de nommage et de répertoire (JNDI).

JsonConfigBasedBoxClientService

Fournit des objets client Box par lesquels les appels d’API Box peuvent être utilisés.

JsonPathReader

Analyse les enregistrements JSON et évalue les chemins JSON définis par l’utilisateur par rapport à chaque objet JSON.

JsonRecordSetWriter

Écrit les résultats de RecordSet sous la forme d’un tableau JSON ou d’un objet JSON par ligne.

Snowflake

JsonTableColumnFilter

Fournit un filtre de colonne de table basé sur une configuration JSON.

JsonTreeReader

Analyse JSON en objets d’enregistrement individuels.

JWTBearerOAuth2AccessTokenProvider

Fournit 2 OAuth.

K

Contrôleur

Description

Kafka3ConnectionService

Fournit et gère les connexions aux Brokers Kafka pour les opérations de producteurs ou de consommateurs.

Snowflake

Kafka3ConnectionService

Fournit et gère les connexions aux Brokers Kafka pour les opérations de producteurs ou de consommateurs.

L

Contrôleur

Description

LoggingRecordSink

Fournit un RecordSinkService qui peut être utilisé pour connecter des enregistrements au journal de l’application (nifi-app.

M

Contrôleur

Description

MapCacheClientService

Fournit la possibilité de communiquer avec un MapCacheServer.

MapCacheServer

Fournit un cache de carte (clé/valeur) accessible via une socket.

Snowflake

MicrosoftClientCertificateOAuth2TokenProvider

Fournit des jetons d’accès OAuth2 pour l’API Microsoft Graph en utilisant client_credentials avec un certificat client.

Snowflake

MicrosoftGraphAuthenticationProvider

Fournit l’authentification pour l’API Microsoft Graph, qui peut être utilisée pour interagir avec les services Microsoft 365.

MongoDBControllerService

Fournit un service contrôleur qui configure une connexion à MongoDB et fournit l’accès à cette connexion à d’autres composants liés à Mongo.

MongoDBLookupService

Fournit un service de recherche basé sur MongoDB.

P

Contrôleur

Description

Snowflake

ParquetIcebergWriter

Fournit la sérialisation des enregistrements pour Apache Iceberg en utilisant le formatage d’Apache Parquet

PEMEncodedSSLContextProvider

SSLContext Le fournisseur peut être configuré à l’aide des fichiers de clé privée et de certificat de PEM.

Snowflake

PolarisIcebergCatalog

Fournit l’intégration d’Apache Iceberg avec l’accès au catalogue d’Apache Polaris par l’intermédiaire de REST HTTP

PropertiesFileLookupService

Un service de recherche basé sur un fichier de propriétés rechargeable

R

Contrôleur

Description

ReaderLookup

Fournit un RecordReaderFactory qui peut être utilisé pour sélectionner dynamiquement un autre RecordReaderFactory.

RecordSetWriterLookup

Fournit un RecordSetWriterFactory qui peut être utilisé pour sélectionner dynamiquement un autre RecordSetWriterFactory.

RecordSinkServiceLookup

Fournit un RecordSinkService qui peut être utilisé pour sélectionner dynamiquement un autre RecordSinkService.

RedisConnectionPoolService

Un service qui fournit des connexions à Redis.

RedisDistributedMapCacheClientService

Une implémentation de DistributedMapCacheClient qui utilise Redis comme cache de sauvegarde.

RestLookupService

Utilisez un service REST pour rechercher des valeurs.

S

Contrôleur

Description

S3FileResourceService

Fournit une ressource de fichier S3 d’Amazon Web Services (AWS) pour d’autres composants.

Snowflake

SalesforceDataCloudOAuthTokenProvider

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.

ScriptedLookupService

Permet à l’utilisateur de fournir une instance LookupService scriptée afin d’enrichir les enregistrements d’un fichier de flux entrant.

ScriptedReader

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.

ScriptedRecordSetWriter

Permet à l’utilisateur de fournir une instance RecordSetWriterFactory scriptée afin d’écrire des enregistrements dans un fichier de flux sortant.

ScriptedRecordSink

Permet à l’utilisateur de fournir une instance RecordSinkService scriptée afin de transmettre des enregistrements à la cible souhaitée.

SetCacheClientService

Fournit la possibilité de communiquer avec un SetCacheServer.

SetCacheServer

Fournit un cache d’ensemble (collection de valeurs uniques) auquel on peut accéder par l’intermédiaire d’une socket.

SimpleCsvFileLookupService

Un service de recherche basé sur le fichier CSV rechargeable.

SimpleDatabaseLookupService

Un service de recherche basé sur une base de données relationnelle.

SimpleKeyValueLookupService

Permet aux utilisateurs d’ajouter des paires clé/valeur en tant que propriétés définies par l’utilisateur.

SimpleRedisDistributedMapCacheClientService

Une implémentation de DistributedMapCacheClient qui utilise Redis comme cache de sauvegarde.

SimpleScriptedLookupService

Permet à l’utilisateur de fournir une instance LookupService scriptée afin d’enrichir les enregistrements d’un fichier de flux entrant.

SlackRecordSink

Formatez et envoyez des enregistrements à un canal configuré à l’aide de l’API Slack Post Message.

SmbjClientProviderService

Permet l’accès aux sessions SMB avec des identifiants d’authentification partagés.

Snowflake

SnowflakeConnectionService

Fournit des connexions de bases de données poolées aux services Snowflake

Snowflake

SnowflakeDatabaseDialectService

Database Dialect Service supportant Snowflake.

Snowflake

SnowflakeSignJWTService

Snowflake

SnowflakeTableSchemaRegistry

Snowflake

StandardAnthropicLLMService

Un Controller Service qui fournit une intégration avec les modèles Claude AI d’Anthropic par le biais de leurs API de messages.

StandardAzureCredentialsControllerService

Fournissez les identifiants à utiliser avec un client Azure.

Snowflake

StandardDatabricksWorkspaceClientService

Client Databricks.

StandardDropboxCredentialService

Définit les identifiants de connexion pour les processeurs Dropbox.

StandardFileResourceService

Fournit une ressource de fichier pour d’autres composants.

StandardHashiCorpVaultClientService

Un service de contrôleur pour interagir avec HashiCorp Vault.

StandardHttpContextMap

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

StandardHubSpotClientService

HubSpot Controller Service pour l’intégration avec l’api HubSpot HTTP.

StandardJsonSchemaRegistry

Fournit un service pour l’enregistrement et l’accès aux schémas JSON.

StandardKustoIngestService

Envoie des lots de contenus de fichiers de flux ou des flux de contenus de fichiers de flux à un cluster Azure ADX.

StandardKustoQueryService

Mise en œuvre standard du service de requête Kusto pour Azure Data Explorer

Snowflake

StandardMilvusConnectionService

Fournit un service de connexion à une instance Milvus

StandardOauth2AccessTokenProvider

Fournit 2 OAuth.

Snowflake

StandardOCRService

Fournit une intégration au service Openflow OCR

Snowflake

StandardOpenAILLMService

Un Controller Service qui assure l’intégration avec l’API Chat Completion d’OpenAI.

StandardPGPPrivateKeyService

Le service de clé privée PGP fournit des clés privées chargées à partir de fichiers ou de propriétés

StandardPGPPublicKeyService

Service de clés publiques PGP fournissant des clés publiques chargées à partir de fichiers

StandardPrivateKeyService

Le service de clé privée permet d’accéder à une clé privée chargée à partir de sources configurées

StandardProxyConfigurationService

Fournit un ensemble de configurations pour différents composants de NiFi afin d’utiliser un serveur proxy.

StandardRestrictedSSLContextService

Mise en œuvre restreinte du site SSLContextService.

StandardS3EncryptionService

Ajoute un chiffrement configurable aux opérations S3 Put et S3 Fetch.

Snowflake

StandardSalesforceClientService

Fournit un service de connexion aux APIs Salesforce

Snowflake

StandardSalesforceDataCloudClientService

Fournit un service de connexion aux APIs Salesforce Data Cloud

StandardSSLContextService

Mise en œuvre standard du site SSLContextService.

Snowflake

StandardTableStateService

Un service de contrôleur qui fournit et gère l’état de la table.

Snowflake

StandardVectaraClientService

Vectara Controller Service pour l’intégration avec Vectara HTTP Api.

StandardWebClientServiceProvider

Fournisseur de services pour le client Web avec prise en charge de la configuration des propriétés de connexion standard de HTTP

Snowflake

StateManagedCdcSchemaRegistry

Utilise la gestion d’état intégrée NiFi pour stocker les hachages des schémas de table.

Syslog5424Reader

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.

SyslogReader

Tente d’analyser le contenu d’un message Syslog conformément à RFC5424 et RFC3164.

U

Contrôleur

Description

UDPEventRecordSink

Formatage et envoi des enregistrements sous forme de paquets de datagrammes UDP vers une destination configurable

V

Contrôleur

Description

VolatileSchemaCache

Fournit un cache de schéma qui évacue les éléments sur la base d’un algorithme de moindre utilisation.

W

Contrôleur

Description

WindowsEventLogReader

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

XMLFileLookupService

Un service de recherche basé sur le fichier XML rechargeable.

XMLReader

Lit le contenu de XML et crée des objets d’enregistrement.

XMLRecordSetWriter

Écrit une page RecordSet sur XML.

Y

Contrôleur

Description

YamlTreeReader

Analyse YAML en objets d’enregistrement individuels.