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 |
|
---|---|---|
Definiert Anmeldeinformationen für ADLS-Prozessoren. |
||
Stellt einen ADLSCredentialsService zur Verfügung, der zur dynamischen Auswahl eines anderen ADLSCredentialsService verwendet werden kann. |
||
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. |
||
Bietet und verwaltet Verbindungen zu AWS MSK Kafka-Brokern für Produzenten- oder Verbraucher-Operationen. |
||
Snowflake |
Bietet und verwaltet Verbindungen zu AWS MSK Kafka-Brokern für Produzenten- oder Verbraucher-Operationen. |
|
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. |
||
Parst Avro-Daten und gibt jeden Avro-Datensatz als separates Datensatzobjekt zurück. |
||
Schreibt den Inhalt eines RecordSet im binären Avro-Format. |
||
Stellt einen Dienst für die Registrierung von und den Zugriff auf Schemas bereit. |
||
Definiert Anmeldeinformationen für Amazon Web Services-Prozessoren. |
||
Bietet eine Azure Blob Storage-Dateiressource für andere Komponenten. |
||
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. |
||
Stellt eine Azure Data Lake Storage (ADLS)-Dateiressource für andere Komponenten zur Verfügung. |
||
Formatieren und Senden von Datensätzen an Azure Event Hubs |
||
Stellt Anmeldeinformationen für Azure Storage-Prozessoren mithilfe der Azure Storage-Clientbibliothek v12 bereit. |
||
Stellt einen AzureStorageCredentialsService_v12 bereit, der zur dynamischen Auswahl eines anderen AzureStorageCredentialsService_v12 verwendet werden kann. |
C¶
Controller |
Beschreibung |
|
---|---|---|
Parst CEF (Common Event Format)-Ereignisse und gibt jede Zeile als einen Datensatz zurück. |
||
Liest den Schemabezeichner gemäß der Confluent-Codierung als Header, der aus einem Byte-Marker und einer Ganzzahl besteht, die als vier Bytes dargestellt wird. |
||
Schreibt den Schemabezeicher gemäß der Confluent-Codierung als Header, der aus einem Byte-Marker und einer Ganzzahl besteht, die als vier Bytes dargestellt wird |
||
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. |
||
Parst CSV-formatierte Daten und gibt jede Zeile in der CSV-Datei als separaten Datensatz zurück. |
||
Eine nachladbarer, auf CSV-Dateien basierender Nachschlagedienst. |
||
Schreibt den Inhalt eines RecordSet als CSV-Daten. |
D¶
Controller |
Beschreibung |
|
---|---|---|
Snowflake |
Ein Nachschlagedienst, der die Anreicherung mit einer Datenbank über eine vom Benutzer angegebene SQL-Anweisung ermöglicht. |
|
Ein auf einer relationalen Datenbank basierender Nachschlagedienst. |
||
Bietet einen Dienst zum Schreiben von Datensätzen unter Verwendung einer konfigurierten Datenbankverbindung. |
||
Stellt einen Datenbankverbindungs-Pooling-Service bereit. |
||
Stellt eine DBCPService bereit, die zur dynamischen Auswahl einer anderen DBCPService verwendet werden kann. |
||
Stellt Box-Clientobjekte zur Verfügung, über die Box-API-Aufrufe verwendet werden können. |
||
Ermöglicht die Auswahl eines verteilten Map-Cache-Clients, um den mit einem Schlüssel verbundenen Wert abzurufen. |
E¶
Controller |
Beschreibung |
|
---|---|---|
Ein Controller-Dienst für den Zugriff auf einen Elasticsearch-Client unter Verwendung des Elasticsearch (Low-Level) REST-Client. |
||
Sucht einen Datensatz von Elasticsearch Server, der mit der angegebenen Dokument–ID verbunden ist. |
||
Ruft einen Zeichenfolgenwert vom Elasticsearch-Server ab, der mit der angegebenen Dokument-ID verknüpft ist. |
||
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. |
||
Ein Dienst, der Hazelcast eingebettet ausführt und darauf basierende Cache-Instanzen bereitstellt. |
||
Parst ein Microsoft Excel-Dokument und gibt jede Zeile in jedem Tabellenblatt als separaten Datensatz zurück. |
||
Ein Anbieter, der Cache-Instanzen bereitstellt, die von Hazelcast unterstützt werden und außerhalb von NiFi ausgeführt werden. |
F¶
Controller |
Beschreibung |
|
---|---|---|
Schreibt den Inhalt eines RecordSet als Freiformtext. |
G¶
Controller |
Beschreibung |
|
---|---|---|
Definiert Anmeldeinformationen für Google Cloud Platform-Prozessoren. |
||
Bietet eine Google Compute Storage (GCS)-Dateiressource für andere Komponenten. |
||
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 |
|
---|---|---|
Eine Implementierung von DistributedMapCacheClient, die Hazelcast als Backing-Cache verwendet. |
||
Stellt einen Datenbankverbindungs-Pooling-Dienst auf der Grundlage von HikariCP bereit. |
||
FormatiertDatensätze und sendet sie per HTTP-Post an eine konfigurierte URI. |
I¶
Controller |
Beschreibung |
|
---|---|---|
Ein Nachschlagedienst, der verschiedene Arten von Anreicherungsinformationen für IP-Adressen bereitstellt. |
J¶
Controller |
Beschreibung |
|
---|---|---|
Implementierung von WebSocketClientService. |
||
Implementierung von WebSocketServerService. |
||
Bietet einen generischen Dienst zum Erstellen von anbieterspezifischem javax. |
||
Stellt einen Dienst zur Verfügung, mit dem Sie unter Verwendung der Java Naming and Directory Interface (JNDI) eine vorhandene JMSConnectionFactory suchen können. |
||
Stellt Box-Clientobjekte zur Verfügung, über die Box-API-Aufrufe verwendet werden können. |
||
Analysiert JSON-Datensätze und wertet benutzerdefinierte JSON-Pfade für jedes JSON-Objekt aus. |
||
Schreibt die Ergebnisse von RecordSet entweder als JSON-Array oder als ein JSON-Objekt pro Zeile. |
||
Snowflake |
Bietet einen Tabellenspaltenfilter, der auf einer JSON-Konfiguration basiert. |
|
Zerlegt JSON in einzelne Datensatzobjekte. |
||
Bietet OAuth 2. |
K¶
Controller |
Beschreibung |
|
---|---|---|
Bietet und verwaltet Verbindungen zu Kafka Brokern für Produzenten- oder Verbraucheroperationen. |
||
Snowflake |
Bietet und verwaltet Verbindungen zu Kafka Brokern für Produzenten- oder Verbraucheroperationen. |
L¶
Controller |
Beschreibung |
|
---|---|---|
Stellt einen RecordSinkService zur Verfügung, der verwendet werden kann, um Datensätze im Anwendungsprotokoll zu protokollieren (nifi-app. |
M¶
Controller |
Beschreibung |
|
---|---|---|
Bietet die Möglichkeit, mit einem MapCacheServer zu kommunizieren. |
||
Bietet einen Map-Cache (Schlüssel/Wert), auf den über einen Socket zugegriffen werden kann. |
||
Snowflake |
Bietet OAuth2-Zugriffstoken für die Microsoft Graph-API unter Verwendung von client_credentials mit einem Client-Zertifikat. |
|
Snowflake |
Bietet Authentifizierung für die Microsoft Graph-API, das für die Interaktion mit Microsoft 365-Diensten verwendet werden kann. |
|
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. |
||
Stellt einen Lookup-Service auf der Grundlage von MongoDB bereit. |
P¶
Controller |
Beschreibung |
|
---|---|---|
Snowflake |
Bietet Datensatzserialisierung für Apache Iceberg unter Verwendung der Apache Parquet-Formatierung |
|
SSLContext-Anbieter konfigurierbar über PEM Private Key und Zertifikatsdateien. |
||
Snowflake |
Stellt eine Apache Iceberg-Integration mit Apache Polaris-Katalogzugang über REST HTTP bereit. |
|
Ein nachladbarer, auf Eigenschaftsdateien basierender Lookup-Service |
R¶
Controller |
Beschreibung |
|
---|---|---|
Stellt eine RecordReaderFactory bereit, die zur dynamischen Auswahl einer anderen RecordReaderFactory verwendet werden kann. |
||
Stellt eine RecordSetWriterFactory bereit, die zur dynamischen Auswahl einer anderen RecordSetWriterFactory verwendet werden kann. |
||
Stellt einen RecordSinkService bereit, der zur dynamischen Auswahl eines anderen RecordSinkService verwendet werden kann. |
||
Ein Dienst, der Verbindungen zu Redis bietet. |
||
Eine Implementierung von DistributedMapCacheClient, die Redis als Backing-Cache verwendet. |
||
Verwenden Sie einen REST-Dienst, um Werte nachzuschlagen. |
S¶
Controller |
Beschreibung |
|
---|---|---|
Stellt eine Amazon Web Services (AWS) S3 Dateiressource für andere Komponenten bereit. |
||
Snowflake |
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. |
|
Ermöglicht es dem Benutzer, eine skriptgesteuerte LookupService-Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile anzureichern. |
||
Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordReaderFactory Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile zu lesen/parsen/erzeugen. |
||
Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordSetWriterFactory-Instanz bereitzustellen, um Datensätze in ein ausgehendes FlowFile zu schreiben. |
||
Ermöglicht es dem Benutzer, eine skriptgesteuerte RecordSinkService-Instanz bereitzustellen, um Datensätze an das gewünschte Ziel zu übertragen. |
||
Bietet die Möglichkeit, mit einem SetCacheServer zu kommunizieren. |
||
Stellt einen Set-Cache (eine Sammlung eindeutiger Werte) bereit, auf den über einen Socket zugegriffen werden kann. |
||
Eine nachladbarer, auf CSV-Dateien basierender Nachschlagedienst. |
||
Ein auf einer relationalen Datenbank basierender Nachschlagedienst. |
||
Ermöglicht Benutzern, Schlüssel-Wert-Paare als benutzerdefinierte Eigenschaften hinzuzufügen. |
||
Eine Implementierung von DistributedMapCacheClient, die Redis als Backing-Cache verwendet. |
||
Ermöglicht es dem Benutzer, eine skriptgesteuerte LookupService-Instanz bereitzustellen, um Datensätze aus einem eingehenden FlowFile anzureichern. |
||
Formatieren und senden Sie Datensätze mit der Slack Post Message-API an einen konfigurierten Kanal. |
||
Ermöglicht den Zugriff auf SMB-Sitzungen mit gemeinsamen Authentifizierungs-Anmeldeinformationen. |
||
Snowflake |
Stellt gepoolte Datenbankverbindungen zu Snowflake-Diensten bereit |
|
Snowflake |
Datenbank-Dialektdienst mit Unterstützung für Snowflake. |
|
Snowflake |
||
Snowflake |
||
Snowflake |
Ein Controller Service, der über die Messages-API die Integration mit den Claude-AI-Modellen von Anthropic ermöglicht. |
|
Geben Sie Anmeldeinformationen zur Verwendung mit einem Azure-Client an. |
||
Snowflake |
Databricks-Client. |
|
Definiert Anmeldeinformationen für Dropbox-Prozessoren. |
||
Stellt eine Dateiressource für andere Komponenten bereit. |
||
Ein Controller-Dienst für die Interaktion mit HashiCorp Vault. |
||
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 |
HubSpot-Controller Service zur Integration mit der HubSpot HTTP-API. |
|
Stellt einen Dienst für die Registrierung von und den Zugriff auf JSON-Schemas bereit. |
||
Sendet Batches von Flowfile-Inhalten oder Stream-Flowfile-Inhalten an einen Azure ADX -Cluster. |
||
Standardimplementierung des Kusto Query Service für Azure Data Explorer |
||
Snowflake |
Bietet Konnektivität zu einer Milvus-Instanz. |
|
Bietet OAuth 2. |
||
Snowflake |
Bietet Integration in Openflow OCR Service |
|
Snowflake |
Ein Controller Service, der die Integration mit der Chat Completion-API von OpenAI ermöglicht. |
|
PGP Private Key Service bietet private Schlüssel, die aus Dateien oder Eigenschaften geladen werden. |
||
PGP Public Key Service, der öffentliche Schlüssel aus Dateien bereitstellt |
||
Private Key Service bietet Zugriff auf einen privaten Schlüssel, der aus konfigurierten Quellen geladen wird. |
||
Bietet eine Reihe von Konfigurationen für verschiedene NiFi-Komponenten zur Verwendung eines Proxyservers. |
||
Eingeschränkte Implementierung des SSLContextService. |
||
Fügt konfigurierbare Verschlüsselung für S3 Put- und S3 Fetch-Operationen hinzu. |
||
Snowflake |
Bietet einen Verbindungsdienst für Salesforce APIs |
|
Snowflake |
Bietet einen Verbindungsdienst zu Salesforce Data Cloud-APIs |
|
Standardimplementierung des SSLContextService. |
||
Snowflake |
Ein Controller-Dienst, der den Tabellenstatus bereitstellt und verwaltet. |
|
Snowflake |
Vectara Controller Service zur Integration mit der Vectara-HTTP-Api. |
|
Web-Client-Dienstanbieter mit Unterstützung für die Konfiguration von Standard-HTTP-Verbindungseigenschaften |
||
Snowflake |
Verwendet das integrierte NiFi State Management, um die Hashwerte der Tabellenschemas zu speichern. |
|
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. |
||
Versucht, den Inhalt einer Syslog-Meldung in Übereinstimmung mit RFC5424 und RFC3164 zu analysieren. |
U¶
Controller |
Beschreibung |
|
---|---|---|
Formatieren und senden Sie Datensätze als UDP Datagramm-Pakete an ein konfigurierbares Ziel. |
V¶
Controller |
Beschreibung |
|
---|---|---|
Stellt einen Schema-Cache bereit, der Elemente auf der Grundlage eines Least-Recently-Used-Algorithmus entfernt. |
W¶
Controller |
Beschreibung |
|
---|---|---|
Liest die Daten des Windows-Ereignisprotokolls als XML-Inhalt, der von ConsumeWindowsEventLog, ParseEvtx, usw. erzeugt wurde. |
X¶
Controller |
Beschreibung |
|
---|---|---|
Eine nachladbarer, auf XML-Dateien basierender Nachschlagedienst. |
||
Liest den XML-Inhalt und erstellt Datensatzobjekte. |
||
Schreibt ein RecordSet in XML. |
Y¶
Controller |
Beschreibung |
|
---|---|---|
Zerlegt YAML in einzelne Datensatzobjekte. |