Alle Controller (alphabetisch)

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

  • Typ des Controllers (Snowflake oder nicht)

  • Der Name des jeweiligen Controllers

  • Eine Zusammenfassung zu jedem Controller

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.

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.

Snowflake

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 zur Verfügung, der eine Verbindung zu Cosmos DB (Core SQL API ) konfiguriert und den Zugriff auf diese Verbindung für andere Cosmos DB-bezogene Komponenten ermöglicht.

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

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

Snowflake

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.

Snowflake

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.

Snowflake

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.

Snowflake

MicrosoftClientCertificateOAuth2TokenProvider

Bietet OAuth2-Zugriffstoken für die Microsoft Graph-API unter Verwendung von client_credentials mit einem Client-Zertifikat.

Snowflake

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

Snowflake

ParquetIcebergWriter

Bietet Datensatzserialisierung für Apache Iceberg unter Verwendung der Apache Parquet-Formatierung

PEMEncodedSSLContextProvider

SSLContext-Anbieter konfigurierbar über PEM Private Key und Zertifikatsdateien.

Snowflake

PolarisIcebergCatalog

Stellt eine Apache Iceberg-Integration mit Apache Polaris-Katalogzugang über REST HTTP bereit.

PropertiesFileLookupService

Ein nachladbarer, auf Eigenschaftsdateien basierender Lookup-Service

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.

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.

Snowflake

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.

Snowflake

SnowflakeConnectionService

Stellt gepoolte Datenbankverbindungen zu Snowflake-Diensten bereit

Snowflake

SnowflakeDatabaseDialectService

Datenbank-Dialektdienst mit Unterstützung für Snowflake.

Snowflake

SnowflakeSignJWTService

Snowflake

SnowflakeTableSchemaRegistry

Snowflake

StandardAnthropicLLMService

Ein Controller Service, der über die Messages-API die Integration mit den Claude-AI-Modellen von Anthropic ermöglicht.

StandardAzureCredentialsControllerService

Geben Sie Anmeldeinformationen zur Verwendung mit einem Azure-Client an.

Snowflake

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.

Snowflake

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

Snowflake

StandardMilvusConnectionService

Bietet Konnektivität zu einer Milvus-Instanz.

StandardOauth2AccessTokenProvider

Bietet OAuth 2.

Snowflake

StandardOCRService

Bietet Integration in Openflow OCR Service

Snowflake

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.

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.

Snowflake

StandardSalesforceClientService

Bietet einen Verbindungsdienst für Salesforce APIs

Snowflake

StandardSalesforceDataCloudClientService

Bietet einen Verbindungsdienst zu Salesforce Data Cloud-APIs

StandardSSLContextService

Standardimplementierung des SSLContextService.

Snowflake

StandardTableStateService

Ein Controller-Dienst, der den Tabellenstatus bereitstellt und verwaltet.

Snowflake

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

Snowflake

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.