Alle Controller-Dienste (alphabetisch)¶

Unter diesem Thema finden Sie eine Liste aller Openflow Controller-Dienste in alphabetischer Reihenfolge. Die Liste beinhaltet:

Typ des Controller-Dienstes (Snowflake oder nicht)

Der Name jedes Controller-Dienstes

Eine Zusammenfassung der einzelnen Controller-Dienste

A¶

	Controller	Beschreibung
	ADLSCredentialsControllerService	Definiert Anmeldeinformationen für ADLS-Prozessoren.
	ADLSCredentialsControllerServiceLookup	Stellt einen ADLSCredentialsService zur Verfügung, der zur dynamischen Auswahl eines anderen ADLSCredentialsService verwendet werden kann.
	AmazonGlueEncodedSchemaReferenceReader	Liest den Schemabezeichner gemäß AWS Glue Schema-Codierung als Header, der aus zwei Byte-Markierungen und einer 16-Byte-UUID besteht.
	AmazonGlueSchemaRegistry	Stellt eine Schema Registry bereit, die mit der AWS Glue Schema Registry interagiert, sodass die Schemas, die in der Glue Schema Registry gespeichert sind, in NiFi verwendet werden können.
	AmazonMSKConnectionService	Bietet und verwaltet Verbindungen zu AWS MSK Kafka-Brokern für Produzenten- oder Verbraucher-Operationen.
	AmazonMSKConnectionService	Bietet und verwaltet Verbindungen zu AWS MSK Kafka-Brokern für Produzenten- oder Verbraucher-Operationen.
	ApicurioSchemaRegistry	Stellt eine Schema Registry bereit, die mit der Apicurio Schema Registry interagiert, sodass die Schemas, die in der Apicurio Schema Registry gespeichert sind, in NiFi verwendet werden können.
	AvroReader	Parst Avro-Daten und gibt jeden Avro-Datensatz als separates Datensatzobjekt zurück.
	AvroRecordSetWriter	Schreibt den Inhalt eines RecordSet im binären Avro-Format.
	AvroSchemaRegistry	Stellt einen Dienst für die Registrierung von und den Zugriff auf Schemas bereit.
	AWSCredentialsProviderControllerService	Definiert Anmeldeinformationen für Amazon Web Services-Prozessoren.
	AzureBlobStorageFileResourceService	Bietet eine Azure Blob Storage-Dateiressource für andere Komponenten.
	AzureCosmosDBClientService	Stellt einen Controller-Dienst bereit, der eine Verbindung zur Cosmos-DB (Core SQL API) konfiguriert, und bietet anderen Cosmos-DB-bezogenen Komponenten Zugriff auf diese Verbindung.
	AzureDataLakeStorageFileResourceService	Stellt eine Azure Data Lake Storage (ADLS)-Dateiressource für andere Komponenten zur Verfügung.
	AzureEventHubRecordSink	Formatieren und Senden von Datensätzen an Azure Event Hubs
	AzureStorageCredentialsControllerService_v12	Stellt Anmeldeinformationen für Azure Storage-Prozessoren mithilfe der Azure Storage-Clientbibliothek v12 bereit.
	AzureStorageCredentialsControllerServiceLookup_v12	Stellt einen AzureStorageCredentialsService_v12 bereit, der zur dynamischen Auswahl eines anderen AzureStorageCredentialsService_v12 verwendet werden kann.

C¶

	Controller	Beschreibung
	CEFReader	Parst CEF (Common Event Format)-Ereignisse und gibt jede Zeile als einen Datensatz zurück.
	ConfluentEncodedSchemaReferenceReader	Liest den Schemabezeichner gemäß der Confluent-Codierung als Header, der aus einem Byte-Marker und einer Ganzzahl besteht, die als vier Bytes dargestellt wird.
	ConfluentEncodedSchemaReferenceWriter	Schreibt den Schemabezeicher gemäß der Confluent-Codierung als Header, der aus einem Byte-Marker und einer Ganzzahl besteht, die als vier Bytes dargestellt wird
	ConfluentProtobufMessageNameResolver	Löst Protobuf-Meldungsnamen aus dem Confluent Schema Registry-Wire-Dateiformat auf, indem die Meldungsindizes decodiert und der vollqualifizierte Name in der Schemadefinition gesucht wird. Referenzen für das Confluent Wire-Format siehe: https://docs.
	ConfluentSchemaRegistry	Stellt eine Schema Registry bereit, die mit der Confluent Schema Registry interagiert, sodass die Schemas, die in der Confluent Schema Registry gespeichert sind, in NiFi verwendet werden können.
	CSVReader	Parst CSV-formatierte Daten und gibt jede Zeile in der CSV-Datei als separaten Datensatz zurück.
	CSVRecordLookupService	Eine nachladbarer, auf CSV-Dateien basierender Nachschlagedienst.
	CSVRecordSetWriter	Schreibt den Inhalt eines RecordSet als CSV-Daten.

D¶

	Controller	Beschreibung
	DatabaseLookup	Ein Nachschlagedienst, der die Anreicherung mit einer Datenbank über eine vom Benutzer angegebene SQL-Anweisung ermöglicht.
	DatabaseRecordLookupService	Ein auf einer relationalen Datenbank basierender Nachschlagedienst.
	DatabaseRecordSink	Bietet einen Dienst zum Schreiben von Datensätzen unter Verwendung einer konfigurierten Datenbankverbindung.
	DBCPConnectionPool	Stellt einen Datenbankverbindungs-Pooling-Service bereit.
	DBCPConnectionPoolLookup	Stellt eine DBCPService bereit, die zur dynamischen Auswahl einer anderen DBCPService verwendet werden kann.
	DeveloperBoxClientService	Stellt Box-Clientobjekte zur Verfügung, über die Box-API-Aufrufe verwendet werden können.
	DistributedMapCacheLookupService	Ermöglicht die Auswahl eines verteilten Map-Cache-Clients, um den mit einem Schlüssel verbundenen Wert abzurufen.

E¶

	Controller	Beschreibung
	ElasticSearchClientServiceImpl	Ein Controller-Dienst für den Zugriff auf einen Elasticsearch-Client unter Verwendung des Elasticsearch (Low-Level) REST-Client.
	ElasticSearchLookupService	Sucht einen Datensatz von Elasticsearch Server, der mit der angegebenen Dokument–ID verbunden ist.
	ElasticSearchStringLookupService	Ruft einen Zeichenfolgenwert vom Elasticsearch-Server ab, der mit der angegebenen Dokument-ID verknüpft ist.
	EmailRecordSink	Stellt einen RecordSinkService bereit, der zum Versenden von Datensätzen in E-Mails unter Verwendung des angegebenen Writers für die Formatierung verwendet werden kann.
	EmbeddedHazelcastCacheManager	Ein Dienst, der Hazelcast eingebettet ausführt und darauf basierende Cache-Instanzen bereitstellt.
	ExcelReader	Parst ein Microsoft Excel-Dokument und gibt jede Zeile in jedem Tabellenblatt als separaten Datensatz zurück.
	ExternalHazelcastCacheManager	Ein Anbieter, der Cache-Instanzen bereitstellt, die von Hazelcast unterstützt werden und außerhalb von NiFi ausgeführt werden.

F¶

	Controller	Beschreibung
	FreeFormTextRecordSetWriter	Schreibt den Inhalt eines RecordSet als Freiformtext.

G¶

	Controller	Beschreibung
	GCPCredentialsControllerService	Definiert Anmeldeinformationen für Google Cloud Platform-Prozessoren.
	GCSFileResourceService	Bietet eine Google Compute Storage (GCS)-Dateiressource für andere Komponenten.
	GrokReader	Bietet einen Mechanismus zum Lesen von unstrukturierten Textdaten, wie z. B. Protokolldateien, und zum Strukturieren der Daten, sodass sie verarbeitet werden können.

H¶

	Controller	Beschreibung
	HazelcastMapCacheClient	Eine Implementierung von DistributedMapCacheClient, die Hazelcast als Backing-Cache verwendet.
	HikariCPConnectionPool	Stellt einen Datenbankverbindungs-Pooling-Dienst auf der Grundlage von HikariCP bereit.
	HttpRecordSink	FormatiertDatensätze und sendet sie per HTTP-Post an eine konfigurierte URI.

I¶

	Controller	Beschreibung
	IPLookupService	Ein Nachschlagedienst, der verschiedene Arten von Anreicherungsinformationen für IP-Adressen bereitstellt.

J¶

	Controller	Beschreibung
	JettyWebSocketClient	Implementierung von WebSocketClientService.
	JettyWebSocketServer	Implementierung von WebSocketServerService.
	JMSConnectionFactoryProvider	Bietet einen generischen Dienst zum Erstellen von anbieterspezifischem javax.
	JndiJmsConnectionFactoryProvider	Stellt einen Dienst zur Verfügung, mit dem Sie unter Verwendung der Java Naming and Directory Interface (JNDI) eine vorhandene JMSConnectionFactory suchen können.
	JsonConfigBasedBoxClientService	Stellt Box-Clientobjekte zur Verfügung, über die Box-API-Aufrufe verwendet werden können.
	JsonPathReader	Analysiert JSON-Datensätze und wertet benutzerdefinierte JSON-Pfade für jedes JSON-Objekt aus.
	JsonRecordSetWriter	Schreibt die Ergebnisse von RecordSet entweder als JSON-Array oder als ein JSON-Objekt pro Zeile.
	JsonTableColumnFilter	Bietet einen Tabellenspaltenfilter, der auf einer JSON-Konfiguration basiert.
	JsonTreeReader	Zerlegt JSON in einzelne Datensatzobjekte.
	JWTBearerOAuth2AccessTokenProvider	Bietet OAuth 2.

K¶

	Controller	Beschreibung
	Kafka3ConnectionService	Bietet und verwaltet Verbindungen zu Kafka Brokern für Produzenten- oder Verbraucheroperationen.
	Kafka3ConnectionService	Bietet und verwaltet Verbindungen zu Kafka Brokern für Produzenten- oder Verbraucheroperationen.

L¶

	Controller	Beschreibung
	LoggingRecordSink	Stellt einen RecordSinkService zur Verfügung, der verwendet werden kann, um Datensätze im Anwendungsprotokoll zu protokollieren (nifi-app.

M¶

	Controller	Beschreibung
	MapCacheClientService	Bietet die Möglichkeit, mit einem MapCacheServer zu kommunizieren.
	MapCacheServer	Bietet einen Map-Cache (Schlüssel/Wert), auf den über einen Socket zugegriffen werden kann.
	MicrosoftClientCertificateOAuth2TokenProvider	Bietet OAuth2-Zugriffstoken für die Microsoft Graph-API unter Verwendung von client_credentials mit einem Client-Zertifikat.
	MicrosoftGraphAuthenticationProvider	Bietet Authentifizierung für die Microsoft Graph-API, das für die Interaktion mit Microsoft 365-Diensten verwendet werden kann.
	MongoDBControllerService	Stellt einen Controller-Dienst zur Verfügung, der eine Verbindung zu MongoDB konfiguriert und anderen Mongo-bezogenen Komponenten den Zugriff auf diese Verbindung ermöglicht.
	MongoDBLookupService	Stellt einen Lookup-Service auf der Grundlage von MongoDB bereit.

P¶

	Controller	Beschreibung
	ParquetIcebergWriter	Bietet Datensatzserialisierung für Apache Iceberg unter Verwendung der Apache Parquet-Formatierung
	PEMEncodedSSLContextProvider	SSLContext-Anbieter konfigurierbar über PEM Private Key und Zertifikatsdateien.
	PolarisIcebergCatalog	Stellt eine Apache Iceberg-Integration mit Apache Polaris-Katalogzugang über REST HTTP bereit.
	PropertiesFileLookupService	Ein nachladbarer, auf Eigenschaftsdateien basierender Lookup-Service
	ProtobufReader	Analysiert eine Protokollpuffermeldung aus dem Binärformat.

R¶

	Controller	Beschreibung
	ReaderLookup	Stellt eine RecordReaderFactory bereit, die zur dynamischen Auswahl einer anderen RecordReaderFactory verwendet werden kann.
	RecordSetWriterLookup	Stellt eine RecordSetWriterFactory bereit, die zur dynamischen Auswahl einer anderen RecordSetWriterFactory verwendet werden kann.
	RecordSinkServiceLookup	Stellt einen RecordSinkService bereit, der zur dynamischen Auswahl eines anderen RecordSinkService verwendet werden kann.
	RedisConnectionPoolService	Ein Dienst, der Verbindungen zu Redis bietet.
	RedisDistributedMapCacheClientService	Eine Implementierung von DistributedMapCacheClient, die Redis als Backing-Cache verwendet.
	RemoveFieldRecordReader	Ein Wrapper für eine RecordReaderFactory, die das Herausfiltern bestimmter Felder aus NiFi-Datensätzen unterstützt.
	RestLookupService	Verwenden Sie einen REST-Dienst, um Werte nachzuschlagen.

S¶

	Controller	Beschreibung
	S3FileResourceService	Stellt eine Amazon Web Services (AWS) S3 Dateiressource für andere Komponenten bereit.
	SalesforceDataCloudOAuthTokenProvider	Ruft ein OAuth2-Zugriffstoken von Salesforce mit dem konfigurierten OAuth2 Access Token Provider ab und tauscht das Token gegen ein Data Cloud API Token aus.
	ScriptedLookupService	Ermöglicht es dem Benutzer, eine skriptgesteuerte LookupService-Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile anzureichern.
	ScriptedReader	Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordReaderFactory Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile zu lesen/parsen/erzeugen.
	ScriptedRecordSetWriter	Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordSetWriterFactory-Instanz bereitzustellen, um Datensätze in ein ausgehendes FlowFile zu schreiben.
	ScriptedRecordSink	Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordSinkService-Instanz bereitzustellen, um Datensätze an das gewünschte Ziel zu übertragen.
	SetCacheClientService	Bietet die Möglichkeit, mit einem SetCacheServer zu kommunizieren.
	SetCacheServer	Stellt einen Set-Cache (eine Sammlung eindeutiger Werte) bereit, auf den über einen Socket zugegriffen werden kann.
	SimpleCsvFileLookupService	Eine nachladbarer, auf CSV-Dateien basierender Nachschlagedienst.
	SimpleDatabaseLookupService	Ein auf einer relationalen Datenbank basierender Nachschlagedienst.
	SimpleKeyValueLookupService	Ermöglicht Benutzern, Schlüssel-Wert-Paare als benutzerdefinierte Eigenschaften hinzuzufügen.
	SimpleRedisDistributedMapCacheClientService	Eine Implementierung von DistributedMapCacheClient, die Redis als Backing-Cache verwendet.
	SimpleScriptedLookupService	Ermöglicht es dem Benutzer, eine skriptgesteuerte LookupService-Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile anzureichern.
	SlackRecordSink	Formatieren und senden Sie Datensätze mit der Slack Post Message-API an einen konfigurierten Kanal.
	SmbjClientProviderService	Ermöglicht den Zugriff auf SMB-Sitzungen mit gemeinsamen Authentifizierungs-Anmeldeinformationen.
	SnowflakeConnectionService	Stellt gepoolte Datenbankverbindungen zu Snowflake-Diensten bereit
	SnowflakeDatabaseDialectService	Datenbank-Dialektdienst mit Unterstützung für Snowflake.
	SnowflakeSignJWTService	Stellt OAuth2-Zugriffstoken unter Verwendung eines JWT, signiert mit einem in Snowflake gespeicherten Geheimnis bereit.
	SnowflakeTableSchemaRegistry	Verwendet Snowflake-Tabellen als Quelle des Schemas – Verwendet die Snowpipe Streaming REST API.
	StandardAnthropicLLMService	Ein Controller Service, der über die Messages-API die Integration mit den Claude-AI-Modellen von Anthropic ermöglicht.
	StandardAtlassianRequestRateManager	Bietet die Koordination der Ratenbegrenzung für Atlassian API-Aufrufe über mehrere Prozessoren hinweg, um kaskadierende Probleme mit der Ratenbegrenzung zu verhindern.
	StandardAzureCredentialsControllerService	Geben Sie Anmeldeinformationen zur Verwendung mit einem Azure-Client an.
	StandardConfluenceClientService	Stellt den Verbindungsdienst zu Confluence-APIs bereit
	StandardDatabricksWorkspaceClientService	Databricks-Client.
	StandardDropboxCredentialService	Definiert Anmeldeinformationen für Dropbox-Prozessoren.
	StandardFileResourceService	Stellt eine Dateiressource für andere Komponenten bereit.
	StandardHashiCorpVaultClientService	Ein Controller-Dienst für die Interaktion mit HashiCorp Vault.
	StandardHttpContextMap	Bietet die Möglichkeit, HTTP-Anfragen und -Antworten außerhalb eines Prozessors zu speichern und abzurufen, sodass mehrere Prozessoren mit der gleichen HTTP-Anfrage interagieren können.
	StandardHubSpotClientService	HubSpot-Controller Service zur Integration mit der HubSpot HTTP-API.
	StandardJsonSchemaRegistry	Stellt einen Dienst für die Registrierung von und den Zugriff auf JSON-Schemas bereit.
	StandardKustoIngestService	Sendet Batches von Flowfile-Inhalten oder Stream-Flowfile-Inhalten an einen Azure ADX -Cluster.
	StandardKustoQueryService	Standardimplementierung des Kusto Query Service für Azure Data Explorer
	StandardMilvusConnectionService	Bietet Konnektivität zu einer Milvus-Instanz.
	StandardOauth2AccessTokenProvider	Bietet OAuth 2.
	StandardOCRService	Bietet Integration in Openflow OCR Service
	StandardOpenAILLMService	Ein Controller Service, der die Integration mit der Chat Completion-API von OpenAI ermöglicht.
	StandardPGPPrivateKeyService	PGP Private Key Service bietet private Schlüssel, die aus Dateien oder Eigenschaften geladen werden.
	StandardPGPPublicKeyService	PGP Public Key Service, der öffentliche Schlüssel aus Dateien bereitstellt
	StandardPrivateKeyService	Private Key Service bietet Zugriff auf einen privaten Schlüssel, der aus konfigurierten Quellen geladen wird.
	StandardProtobufReader	Analysiert Protokollpuffermeldungen aus dem Binärformat in NiFi-Datensätzen.
	StandardProxyConfigurationService	Bietet eine Reihe von Konfigurationen für verschiedene NiFi-Komponenten zur Verwendung eines Proxyservers.
	StandardRestrictedSSLContextService	Eingeschränkte Implementierung des SSLContextService.
	StandardS3EncryptionService	Fügt konfigurierbare Verschlüsselung für S3 Put- und S3 Fetch-Operationen hinzu.
	StandardSalesforceBulkJobsStateService	Speichert den Status von Salesforce Bulk Jobs pro Objekttyp im Geltungsbereich des Clusters
	StandardSalesforceClientService	Bietet einen Verbindungsdienst für Salesforce APIs
	StandardSalesforceDataCloudClientService	Bietet einen Verbindungsdienst zu Salesforce Data Cloud-APIs
	StandardSlackRateLimiterService	Bietet Koordination der Ratenbegrenzung für Slack API-Aufrufe über mehrere Prozessoren hinweg, um kaskadierende Probleme mit der Ratenbegrenzung zu verhindern.
	StandardSSLContextService	Standardimplementierung des SSLContextService.
	StandardTableStateService	Ein Controller-Dienst, der den Tabellenstatus bereitstellt und verwaltet.
	StandardVectaraClientService	Vectara Controller Service zur Integration mit der Vectara-HTTP-Api.
	StandardWebClientServiceProvider	Web-Client-Dienstanbieter mit Unterstützung für die Konfiguration von Standard-HTTP-Verbindungseigenschaften
	StateManagedCdcSchemaRegistry	Verwendet das integrierte NiFi State Management, um die Hashwerte der Tabellenschemas zu speichern.
	Syslog5424Reader	Stellt einen Mechanismus zum Lesen von RFC 5424-konformen Syslog-Daten bereit, wie z. B. Protokolldateien, und zur Strukturierung der Daten, sodass sie verarbeitet werden können.
	SyslogReader	Versucht, den Inhalt einer Syslog-Meldung in Übereinstimmung mit RFC5424 und RFC3164 zu analysieren.

U¶

	Controller	Beschreibung
	UDPEventRecordSink	Formatieren und senden Sie Datensätze als UDP Datagramm-Pakete an ein konfigurierbares Ziel.

V¶

	Controller	Beschreibung
	VolatileSchemaCache	Stellt einen Schema-Cache bereit, der Elemente auf der Grundlage eines Least-Recently-Used-Algorithmus entfernt.

W¶

	Controller	Beschreibung
	WindowsEventLogReader	Liest die Daten des Windows-Ereignisprotokolls als XML-Inhalt, der von ConsumeWindowsEventLog, ParseEvtx, usw. erzeugt wurde.

X¶

	Controller	Beschreibung
	XMLFileLookupService	Eine nachladbarer, auf XML-Dateien basierender Nachschlagedienst.
	XMLReader	Liest den XML-Inhalt und erstellt Datensatzobjekte.
	XMLRecordSetWriter	Schreibt ein RecordSet in XML.

Y¶

	Controller	Beschreibung
	YamlTreeReader	Zerlegt YAML in einzelne Datensatzobjekte.