Tous les services de contrôleur (par ordre alphabétique)¶

Cette rubrique fournit une liste de tous les services de contrôleur openflow dans l’ordre alphabétique. La liste comprend :

Type de service du contrôleur (Snowflake ou non)

Le nom de chaque service de contrôleur

Un résumé de chaque service de 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.
	AmazonGlueEncodedSchemaReferenceReader	Lit l’identificateur de schéma conformément à l’encodage AWS Glue Schema sous forme d’un en-tête composé de deux marqueurs d’octets et d’un UUID de 16 octets
	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.
	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ôleur qui configure une connexion à Cosmos DB (API SQL 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
	ConfluentProtobufMessageNameResolver	Résout les noms de messages Protobuf à partir du format de transmission Confluent Schema Registry en décodant les index des messages et en recherchant le nom complet dans la définition du schéma. Pour en savoir plus sur le format de transmission Confluent, voir : https://docs.
	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
	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.
	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.
	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.
	MicrosoftClientCertificateOAuth2TokenProvider	Fournit des jetons d’accès OAuth2 pour l’API Microsoft Graph en utilisant client_credentials avec un certificat client.
	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
	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.
	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
	ProtobufReader	Analyse un message Protocol Buffers au format binaire.

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.
	RemoveFieldRecordReader	Une enveloppe pour un RecordReaderFactory qui prend en charge le filtrage des champs spécifiés depuis les enregistrements NiFi.
	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.
	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.
	SnowflakeConnectionService	Fournit des connexions de bases de données poolées aux services Snowflake
	SnowflakeDatabaseDialectService	Database Dialect Service supportant Snowflake.
	SnowflakeSignJWTService	Fournit un jeton d’accès OAuth2 à l’aide d’un JWT signé avec un secret stocké dans Snowflake.
	SnowflakeTableSchemaRegistry	Utilise les tables Snowflake comme source de schéma ; utilise l’API REST Snowpipe Streaming.
	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.
	StandardAtlassianRequestRateManager	Assure la coordination de la limitation du débit pour les appels API Atlassian entre les processeurs afin d’éviter les problèmes de limitation du débit en cascade.
	StandardAzureCredentialsControllerService	Fournissez les identifiants à utiliser avec un client Azure.
	StandardConfluenceClientService	Fournit un service de connexion aux APIs Confluence
	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.
	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
	StandardMilvusConnectionService	Fournit un service de connexion à une instance Milvus
	StandardOauth2AccessTokenProvider	Fournit 2 OAuth.
	StandardOCRService	Fournit une intégration au service Openflow OCR
	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
	StandardProtobufReader	Analyse les messages Protocol Buffers du format binaire vers les enregistrements NiFi.
	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.
	StandardSalesforceBulkJobsStateService	Stocke l’état des tâches groupées de Salesforce par type d’objet à l’échelle du cluster
	StandardSalesforceClientService	Fournit un service de connexion aux APIs Salesforce
	StandardSalesforceDataCloudClientService	Fournit un service de connexion aux APIs Salesforce Data Cloud
	StandardSlackRateLimiterService	Assure la coordination de la limitation du débit pour les appels API Slack entre les processeurs afin d’éviter les problèmes de limitation du débit en cascade
	StandardSSLContextService	Mise en œuvre standard du site SSLContextService.
	StandardTableStateService	Un service de contrôleur qui fournit et gère l’état de la table.
	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
	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.