Alle Prozessoren (alphabetisch)¶
Unter diesem Thema finden Sie eine Liste aller Snowflake Openflow-Prozessoren in alphabetischer Reihenfolge. Die Liste beinhaltet:
Der Name des jeweiligen Prozessors
Eine Zusammenfassung zu jedem Prozessor
A¶
Prozessor |
Beschreibung |
|
---|---|---|
Snowflake |
Bricht eine Abfrage in Salesforce mit der Bulk-API 2 ab. |
|
Erstellt eine CSV-Darstellung der Attribute des Eingabe-FlowFile. |
||
Erstellt eine JSON-Darstellung der Attribute des Eingabe-FlowFile. |
C¶
Prozessor |
Beschreibung |
|
---|---|---|
Zählt die Anzahl der Datensätze in einer Datensatzgruppe, optional auch die Anzahl der Elemente pro Kategorie, wobei die Kategorien durch benutzerdefinierte Eigenschaften definiert sind. |
||
Snowflake |
Liest CDC-Ereignisse aus einer MySQL-Datenbank. |
|
Snowflake |
Liest CDC-Ereignisse aus einer PostgreSQL-Datenbank. |
|
Snowflake |
Liest CDC-Ereignisse aus einer SQL-Server-Datenbank. |
|
Snowflake |
Erfasst Änderungen an einem Shared Google Drive und sendet für jede Änderung ein FlowFile. |
|
Snowflake |
Erfasst Änderungen an Microsoft365-Gruppen und sendet für jede Änderung ein FlowFile. |
|
Snowflake |
Erfasst Änderungen in einer SharePoint-Dokumentbibliothek und sendet für jede Änderung ein FlowFile. |
|
Snowflake |
Prozessor, der prüft, ob der Meta Ads-Bericht zum Download bereit ist. |
|
Snowflake |
Teilt Text mit Optionen für die rekursive Aufteilung anhand von Trennzeichen und maximaler Zeichenlänge in Blöcke auf. |
|
Snowflake |
Teilt Text mit Optionen für die rekursive Aufteilung anhand von Trennzeichen und maximaler Zeichenlänge in Blöcke auf. |
|
Komprimiert oder dekomprimiert den Inhalt von FlowFiles mit einem vom Benutzer angegebenen Komprimierungsalgorithmus und aktualisiert das Mime-Format. |
||
Dient als WebSocket-Client-Endpunkt zur Interaktion mit einem Remote-WebSocket-Server. |
||
Empfängt AMQP-Meldungen von einem AMQP-Broker unter Verwendung von AMQP 0. |
||
Empfängt Meldungen von Microsoft Azure Event Hubs mit Checkpoints, um eine konsistente Ereignisverarbeitung sicherzustellen. |
||
Empfängt Enterprise-Ereignisse aus dem Stream-Typ „admin_logs_streaming“ von Box. |
||
Verarbeitet alle Ereignisse von Box. |
||
Ein Prozessor, der wiederholt eine paginierte Abfrage auf ein Feld unter Verwendung einer Bereichsabfrage (Range Query) durchführt, um neue Dokumente aus einem Elasticsearch-Index/einer Elasticsearch-Abfrage zu verarbeiten. |
||
Verarbeitet Meldungen aus dem konfigurierten Google Cloud PubSub-Abonnement. |
||
Verarbeitet Meldungen vom E-Mail-Server über das IMAP-Protokoll. |
||
Verarbeitet JMS-Meldungen des Typs BytesMessage, TextMessage, ObjectMessage, MapMessage oder StreamMessage, wandelt ihren Inhalt in ein FlowFile um und überführt es in die Beziehung „success“. |
||
Verarbeitet Meldungen von der Apache Kafka Consumer-API. |
||
Snowflake |
Verarbeitet Meldungen von der Apache Kafka Consumer-API. |
|
Liest Daten aus dem angegebenen AWS Kinesis-Stream und gibt ein FlowFile für jeden verarbeiteten Datensatz (roh) oder eine FlowFile für einen Batch verarbeiteter Datensätze aus, wenn ein Record Reader und Record Writer konfiguriert sind. |
||
Abonniert ein Thema und empfängt Meldungen von einem MQTT-Broker |
||
Verarbeitet Meldungen vom E-Mail-Server über das POP3-Protokoll. |
||
Ruft Meldungen aus einem oder mehreren konfigurierten Slack-Kanälen ab. |
||
Snowflake |
Ruft Meldungen aus Slack-Konversationen ab, die für die App verfügbar sind. |
|
Snowflake |
Ruft historische Meldungen aus allen für die App verfügbaren Slack-Kanälen ab. |
|
Snowflake |
Ruft Daten aus einem Snowflake-Stream ab und schreibt sie in ein FlowFile. |
|
Streamt Tweets von Twitters Streaming-API v2. |
||
Steuert die Geschwindigkeit, mit der Daten an die Folgeprozessoren übertragen werden. |
||
Konvertiert den Inhalt eines FlowFile von einem Zeichensatz in einen anderen |
||
Konvertiert Datensätze mithilfe der konfigurierten Controller Services Record Reader- und Record Writer von einem Datenformat in ein anderes. |
||
Snowflake |
Konvertiert das eingehende Datenbankschema in das entsprechende Schema für eine Snowflake CDC-Journaltabelle. |
|
Kopiert einen Blob in Azure Blob Storage von einem Konto/Container in einen anderen. |
||
Kopiert eine Datei von einem Bucket und Schlüssel in einen anderen in AWS S3 |
||
Zählt verschiedene Metriken für eingehenden Text. |
||
Snowflake |
Prozessor, der die Berichtskonfiguration für den Amazon Ads Connector erstellt. |
|
Snowflake |
Verwendet Azure OpenAI, um Einbettungen für Text zu erstellen. |
|
Erzeugt eine Metadateninstanz für eine Box-Datei unter Verwendung einer angegebenen Vorlage mit Werten aus dem FlowFile-Inhalt. |
||
Erzeugt eine Box-Metadatenvorlage unter Verwendung von Feldspezifikationen aus dem FlowFile-Inhalt. |
||
Snowflake |
Verwendet Cohere, um Einbettungen für Text zu erstellen. |
|
Snowflake |
Prozessor, der die Berichtskonfiguration für den Meta Ads Connector erstellt. |
|
Snowflake |
Verwendet OpenAI, um Einbettungen für Text zu erstellen. |
|
Snowflake |
Vektoreinbettungen mit den Funktionen des Snowflake Cortex Large Language Model erstellen |
|
Snowflake |
Verwendet VertexAI, um Einbettungen für Text zu erstellen. |
|
Berechnet einen kryptografischen Hashwert für den Inhalt des FlowFile unter Verwendung des angegebenen Algorithmus und schreibt ihn in ein Ausgabeattribut. |
D¶
Prozessor |
Beschreibung |
|
---|---|---|
Der DebugFlow-Prozessor unterstützt Testen und Debuggen des FlowFile-Frameworks, indem er es ermöglicht, verschiedene Antworten explizit als Reaktion auf den Empfang eines FlowFile oder eines Timer-Ereignisses ohne FlowFile auszulösen, wenn Sie eine Timer- oder Cron-basierte Zeitplanung verwenden. |
||
Entschlüsselt Inhalte mit der Age-Verschlüsselung. |
||
Entschlüsselt den Inhalt von OpenPGP-Meldungen. |
||
Dieser Prozessor dedupliziert Datensätze innerhalb einer Datensatzgruppe. |
||
Löscht den angegebenen Blob aus Azure Blob Storage. |
||
Löscht die bereitgestellte Datei aus Azure Data Lake Storage. |
||
Löscht eine Metadateninstanz aus einer Box-Datei unter Verwendung des angegebenen Vorlagenschlüssels |
||
Löscht aus einem Elasticsearch-Index mithilfe einer Abfrage. |
||
Snowflake |
Löscht DBFS-Dateien und Verzeichnisse. |
|
Löscht ein Dokument aus DynamoDB basierend auf einem Hashwert und einem Bereichsschlüssel. |
||
Löscht eine Datei aus dem Dateisystem. |
||
Löscht Objekte aus einem Google Cloud Bucket. |
||
Löscht eine Datei von GridFS anhand eines Dateinamens oder einer Abfrage. |
||
Snowflake |
Löscht Vektoren anhand ihrer ID aus der Milvus-Datenbank aus einer Sammlung. |
|
Führt eine Abfrage zum Löschen in einer MongoDB-Sammlung aus. |
||
Snowflake |
Löscht Vektoren aus einem Pinecone-Index. |
|
Snowflake |
Löscht einen Abfrageauftrag in Salesforce mit der Bulk-API 2. |
|
Löscht eine Datei aus einem Amazon S3-Bucket. |
||
Löscht eine Datei, die sich auf einem SFTP-Server befindet. |
||
Löscht eine Meldung aus einer Amazon Simple Queuing Service-Warteschlange. |
||
Snowflake |
Löscht ein/e Unity Catalog-Datei oder -Verzeichnis. |
|
Snowflake |
Beschreiben Sie die angegebenen Metadaten zur Datenfreigabe in Salesforce Data Cloud. |
|
Snowflake |
Beschreibt die angegebenen Objektmetadaten in Salesforce. |
|
Speichert einen Wert, der aus FlowFile-Attributen berechnet wird, für jedes eingehende FlowFile und stellt fest, ob der gespeicherte Wert bereits gesehen wurde. |
||
Verteilt FlowFiles auf der Grundlage einer Verteilungsstrategie an nachgelagerte Prozessoren. |
||
Dieser Prozessor ist für Lasttests vorgesehen und erstellt die konfigurierte Anzahl von Kopien jedes eingehenden FlowFile. |
E¶
Prozessor |
Beschreibung |
|
---|---|---|
Codiert oder decodiert den Inhalt eines FlowFile mit Base64-, Base32- oder Hex-Codierungsschemas. |
||
Verschlüsselt Inhalte mit der Age-Verschlüsselung. |
||
Verschlüsselt Inhalte mit OpenPGP. |
||
Erzwingt die erwartete Reihenfolge von FlowFiles, die innerhalb eines einzelnen Knotens zur gleichen Datengruppe gehören. |
||
Snowflake |
Sucht einen Wert mithilfe des konfigurierten Nachschlagedienstes und fügt die Ergebnisse als ein oder mehrere Attribute zum FlowFile hinzu. |
|
Snowflake |
Reichert die eingehenden FlowFilesan, die von CaptureChangePostgreSQL usw. kommen. |
|
Bewerten einen oder mehrere JsonPath-Ausdrücke anhand des Inhalts eines FlowFile. |
||
Snowflake |
Bewertet die Korrektheit der generierten Antworten in einem Retrieval-Augmented-Generation (RAG)-Kontext durch die Berechnung von Metriken wie F1-Score, Kosinusähnlichkeit und Korrektheit der Antworten. |
|
Snowflake |
Bewertet die Genauigkeit der generierten Antworten in einem Retrieval-Augmented Generation (RAG)-System durch Analyse der Antworten mithilfe eines LLM (e. |
|
Snowflake |
Berechnet Abrufmetriken (Precision@N, Recall@N, FScore@N, MAP@N, MRR) für einRAG-System unter Verwendung eines LLM als Bewertungsinstanz. |
|
Bewertet eine oder mehrere XPaths anhand des Inhalts eines FlowFile. |
||
Bewertet eine oder mehrere XQueries anhand des Inhalts eines FlowFile. |
||
Experimenteller erweiterter Groovy-Skriptprozessor. |
||
Führt einen vom Benutzer angegebenen Betriebssystembefehl aus und schreibt die Ausgabe dieses Befehls in ein FlowFile. |
||
Experimentell – Führt ein Skript mit dem FlowFile und einer Prozesssitzung aus. |
||
Führt die bereitgestellte SQL-Select-Abfrage aus. |
||
Führt die bereitgestellte SQL-Select-Abfrage aus. |
||
Snowflake |
Führt eine SQL DDL- oder DML-Anweisung gegen eine Datenbank aus. |
|
Der ExecuteStreamCommand-Prozessor bietet eine flexible Möglichkeit, externe Befehle und Skripte in NiFi-Datenflüsse zu integrieren. |
||
Extrahiert Metadaten aus dem Header einer Avro-Datendatei. |
||
Extrahiert Anhänge aus einer E-Mail-Datei im Mime-Format und teilt sie in einzelne FlowFiles auf. |
||
Extrahiert unter Verwendung des FlowFile-Inhalts als Datenquelle den Header aus einer RFC-konformen E-Mail-Datei und fügt die entsprechenden Attribute zum FlowFile hinzu. |
||
Wertet einen oder mehrere Grok-Ausdrücke gegen den Inhalt eines FlowFile aus, fügt die Ergebnisse als Attribute hinzu oder ersetzt den Inhalt des FlowFile durch eine JSON-Notation des übereinstimmenden Inhalts. |
||
Extrahiert das Datensatzschema aus FlowFile mithilfe des mitgelieferten Record Reader und schreibt es in die „avro. |
||
Snowflake |
Extrahiert die Spalten des Datensatzschemas aus dem FlowFile mithilfe des mitgelieferten Record Reader und schreibt sie in das Schema. |
|
Extrahiert Metadaten aus einer Box-Datei mit Box AI. |
||
Wertet einen oder mehrere reguläre Ausdrücke gegen den Inhalt eines FlowFile aus. |
F¶
Prozessor |
Beschreibung |
|
---|---|---|
Ruft den angegebenen Blob aus Azure Blob Storage ab und schreibt seinen Inhalt in den Inhalt des FlowFile. |
||
Ruft die angegebene Datei aus Azure Data Lake Storage ab. |
||
Ruft Dateien aus einem Box-Ordner ab. |
||
Holt Metadaten für Dateien aus Box und fügt sie den Attributen des FlowFile hinzu. |
||
Ruft bestimmte Metadateninstanzen ab, die mit einer Box-Datei verknüpft sind, unter Verwendung eines Vorlagenschlüssels und eines Bereichs. |
||
Holt eine Box-Dateidarstellung unter Verwendung eines Darstellungshinweises und schreibt sie in den Inhalt des FlowFile. |
||
Berechnet den/die Cache-Schlüssel aus FlowFile-Attributen für jedes eingehende FlowFile und ruft den/die Wert(e) aus dem verteilten Map-Cache ab, der mit jedem Schlüssel verbunden ist. |
||
Ruft Dateien aus Dropbox ab. |
||
Liest den Inhalt einer Datei von der Festplatte und streamt ihn in den Inhalt eines eingehenden FlowFile. |
||
Ruft den Inhalt einer Datei von einem Remote-FTP-Server ab und überschreibt den Inhalt eines eingehenden FlowFile mit dem Inhalt der Remote-Datei. |
||
Ruft eine Datei aus einem Google Cloud Bucket ab. |
||
Ruft Dateien aus einem Google Drive-Ordner ab. |
||
Snowflake |
Ruft Kommentare und ihre Antworten für eine Google Drive-Datei ab. |
|
Snowflake |
Ruft die Metadaten von Google Drive-Dateien ab. |
|
Ruft eine oder mehrere Dateien aus einem GridFS-Bucket nach Dateinamen oder durch eine benutzerdefinierte Abfrage ab. |
||
Snowflake |
Ruft Vorgänge aus Jira Cloud unter Verwendung der REST-API v3 mit konfigurierbaren Suchoptionen ab. |
|
Snowflake |
Ruft Datensätze aus Microsoft Dataverse-Tabellen ab |
|
Ruft den Inhalt eines S3-Objekts ab und schreibt ihn in den Inhalt eines FlowFile |
||
Ruft den Inhalt einer Datei von einem Remote-SFTP-Server ab und überschreibt den Inhalt eines eingehenden FlowFile mit dem Inhalt der Remote-Datei. |
||
Snowflake |
Ruft den Inhalt einer Datei von einem SharePoint-Laufwerk ab und lädt optional eine PDF- oder HTML-Version der Datei herunter, falls zutreffend. |
|
Snowflake |
Für jedes Laufwerkselement werden die Metadaten und Berechtigungen abgerufen und als FlowFile-Attribute geschrieben. |
|
Snowflake |
Ruft Informationen zu Slack-Konversationen und E-Mails von Mitgliedern ab. |
|
Snowflake |
Lädt eine auf Slack freigegebene Datei herunter. |
|
Snowflake |
Ruft Daten über eine einzelne Slack-Meldung ab. |
|
Ruft Dateien von einer SMB-Freigabe ab. |
||
Snowflake |
Liest Eigenschaften aus einer Tabelle und speichert sie als Attribute eines FlowFile. |
|
Snowflake |
Holt das Tabellenschema (i. |
|
Snowflake |
Holt einen Snapshot einer Tabelle aus einer Datenbank. |
|
Filtert die Attribute eines FlowFile, indem bestimmte Attribute beibehalten werden und der Rest entfernt wird oder indem bestimmte Attribute entfernt werden und der Rest beibehalten wird. |
||
Snowflake |
Findet ein SharePoint Drive-Objekt anhand seiner Laufwerks-ID und seines Elementpfads. |
|
Bietet dem Benutzer die Möglichkeit, ein verschachteltes JSON-Dokument in ein einfaches Schlüssel-Wertpaar-Dokument umzuwandeln. |
||
In Verbindung mit dem JoinEnrichment-Prozessor ist dieser Prozessor für das Hinzufügen der Attribute zuständig, die der JoinEnrichment -Prozessor benötigt, um seine Funktion zu erfüllen. |
||
Dieser Prozessor ermöglicht es dem Benutzer, einen Datensatz in mehrere Datensätze aufzuteilen. |
G¶
Prozessor |
Beschreibung |
|
---|---|---|
Snowflake |
Generiert synthetische Antworten für jede Frage in den eingehenden Datensätzen unter Verwendung eines Large Language Model (LLM). |
|
Snowflake |
Erzeugt synthetische Antworten für jede Frage in den eingehenden Datensätzen unter Verwendung eines LLM. |
|
Dieser Prozessor erstellt FlowFiles mit zufälligen Daten oder benutzerdefinierten Inhalten. |
||
Snowflake |
Erzeugt einen Batch von JSON-Objekten mit zufälligen Feldwerten auf der Grundlage eines konfigurierbaren JSON-Schemas. |
|
Dieser Prozessor erstellt FlowFiles mit Datensätzen, die Zufallswerte für die angegebenen Felder enthalten. |
||
Erzeugt SQL-Select-Abfragen, die „Seiten“ von Zeilen aus einer Tabelle abrufen. |
||
Sucht Geolokalisierungsinformationen für eine IP-Adresse und fügt die Geoinformationen zu den FlowFile-Attributen hinzu. |
||
Sucht Geolokalisierungsinformationen für eine IP-Adresse und fügt die Geoinformationen zu den FlowFile-Attributen hinzu. |
||
Snowflake |
Der Prozessor lädt den Bericht von Amazon Ads herunter, wenn er bereit ist. |
|
Ruft den aktuellen Status eines AWS Polly-Jobs ab. |
||
Ruft den aktuellen Status eines AWS Textract-Auftrags ab. |
||
Ruft den aktuellen Status eines AWS Transcribe-Jobs ab. |
||
Ruft den aktuellen Status eines AWS Translate-Jobs ab. |
||
Empfängt Meldungen von Microsoft Azure Event Hubs ohne zuverlässige Checkpoint-Verfolgung. |
||
Ruft die Meldungen aus einem Azure-Warteschlangenspeicher ab. |
||
Ruft alle Teilnehmer in einer Box-Datei ab und fügt die Informationen zur Zusammenarbeit zu den Attributen der FlowFile hinzu. |
||
Ruft Mitglieder für eine Box-Gruppe ab und schreibt ihre Details in FlowFile-Attribute. |
||
Snowflake |
Beschreiben Sie die angegebenen Metadaten zur Datenfreigabe in Salesforce Data Cloud. |
|
Snowflake |
Beschreiben Sie die angegebenen Metadaten zur Datenfreigabe in Salesforce Data Cloud. |
|
Snowflake |
Liest eine DBFS-Datei. |
|
Ruft ein Dokument von DynamoDB ab, basierend auf einem Hashwert und einem Bereichsschlüssel. |
||
Elasticsearch-Get-Prozessor, der die offiziellen Elastic REST-Client-Bibliotheken verwendet, um ein einzelnes Dokument anhand seiner _id aus Elasticsearch abzurufen. |
||
Erzeugt FlowFiles aus den Dateien in einem Verzeichnis. |
||
Dieser Prozessor erstellt FlowFiles mit dem Inhalt der konfigurierten Dateiressource. |
||
Ruft Dateien von einem FTP-Server ab und erstellt daraus FlowFiles |
||
Ruft den aktuellen Status einer Google Vision-Operation ab. |
||
Ruft den aktuellen Status einer Google Vision-Operation ab. |
||
Snowflake |
Ein Prozessor, der mit der Google Ads Reporting-API interagieren kann. |
|
Snowflake |
Ruft die Mitglieder einer oder mehrerer Google-Gruppen ab, die als durch Kommas getrennte Liste der Gruppen-IDs angegeben sind, die als FlowFile-Attribut angegeben wird. |
|
Snowflake |
Prozessor, der für das Abrufen von Daten aus Google Sheets zuständig ist. |
|
Ruft JSON-Daten aus einer privaten HubSpot-Anwendung ab. |
||
Snowflake |
Ruft ein HubSpot-Objekt und seine Verknüpfungen über die ID oder einen eindeutigen Wert ab. |
|
Snowflake |
Prozessoren, die Metriken von LinkedIn Reporting-APIs herunterladen. |
|
Snowflake |
Ruft Microsoft365-Gruppenmitglieder ab und sendet bei jeder Änderung ein FlowFile. |
|
Erstellt FlowFiles aus Dokumenten in MongoDB, die durch eine vom Benutzer angegebene Abfrage geladen wurden. |
||
Eine datensatzbasierte Version von GetMongo, die von den Record Writers verwendet wird, um das Resultset MongoDB zu schreiben. |
||
Snowflake |
Ruft die Ergebnisse eines Abfragejobs in Salesforce über die Bulk-API ab. 2. |
|
Snowflake |
Ruft den Status eines Abfragejobs in Salesforce über die Funktion Bulk-API 2 ab. |
|
Prüft, ob ein Objekt in S3 vorhanden ist, und ruft seine Metadaten ab, ohne zu versuchen, es herunterzuladen. |
||
Überprüft, ob ein Objekt in S3 vorhanden ist, und ruft dessen Tags ab, ohne zu versuchen, es herunterzuladen. |
||
Ruft Dateien von einem SFTP-Server ab und erstellt daraus FlowFiles |
||
Snowflake |
Ruft alle Mitglieder einer SharePoint-Website-Gruppe ab. |
|
Ruft Objekte aus einem benutzerdefinierten Shopify-Shop ab. |
||
Liest eine Datei von einem Samba-Netzwerkspeicherort in FlowFiles. |
||
Ruft Daten von Splunk Enterprise ab. |
||
Ruft Meldungen aus einer Amazon Simple Queuing Service-Warteschlange ab |
||
Snowflake |
Liest eine Unity Catalog-Datei mit bis zu 5 GiB. |
|
Snowflake |
Prüft, ob die Metadaten der Unity Catalog-Datei vorhanden sind. |
|
Ein Prozessor, der mit einem konfigurierbaren Workday-Bericht interagieren kann. |
||
Ruft inkrementell Daten aus der Zendesk-API ab. |
H¶
Prozessor |
Beschreibung |
|
---|---|---|
Startet einen HTTP-Server und überwacht auf HTTP-Anfragen. |
||
Sendet eine HTTP-Antwort an den Absender, der ein FlowFile generiert hat. |
I¶
Prozessor |
Beschreibung |
|
---|---|---|
Versucht, den MIME-Typ zu identifizieren, der für ein FlowFile verwendet wird. |
||
Ein HTTP-Client-Prozessor, der mit einem konfigurierbaren HTTP-Endpunkt interagieren kann. |
||
Experimentell – Ruft eine Skript-Engine für einen im angegebenen Skript definierten Prozessor auf. |
||
Sucht nach ISP-Informationen für eine IP-Adresse und fügt die Informationen zu FlowFile-Attributen hinzu. |
J¶
Prozessor |
Beschreibung |
|
---|---|---|
Fügt Datensätze aus zwei verschiedenen FlowFiles zusammen, wobei ein FlowFile, das „Original“, beliebige Datensätze enthält und das zweite FlowFile, die „Anreicherung“, zusätzliche Daten enthält, die zur Anreicherung des ersten verwendet werden sollen. |
||
Wendet eine Liste von Jolt-Spezifikationen entweder auf den Inhalt von FlowFile JSON oder auf ein bestimmtes FlowFile JSON -Attribut an. |
||
Wendet eine JOLT-Spezifikation auf jeden Datensatz in der FlowFile-Nutzlast an. |
||
Wendet eine JSLT-Transformation auf die FlowFile JSON-Nutzlast an. |
||
Ein Prozessor, mit dem der Benutzer eine Abfrage (mit Aggregationen) ausführen kann, die mit Elasticsearch JSON DSL geschrieben wurde. |
L¶
Prozessor |
Beschreibung |
|
---|---|---|
Snowflake |
Listet die archivierten Daten aus dem HubSpot für den gewählten Objekttyp auf und erzeugt ein FlowFile pro aufgelistetem Objekt mit den entsprechenden Metadaten als FlowFile-Attribut. |
|
Listet Blobs in einem Azure Blob Storage-Container auf. |
||
Listet das Verzeichnis in einem Azure Data Lake Storage Gen 2-Dateisystem auf |
||
Listet die Dateien in einem Box-Ordner auf. |
||
Holt die Datei-Metadaten für jede Datei in einem Box-Ordner. |
||
Ruft alle Metadateninstanzen ab, die mit einer Box-Datei verbunden sind. |
||
Ruft alle Metadatenvorlagen ab, die mit einer Box-Datei verbunden sind. |
||
Erzeugt eine Reihe von FlowFiles, die jeweils Attribute enthalten, die den Metadaten einer Tabelle aus einer Datenbankverbindung entsprechen. |
||
Snowflake |
Listet die Dateinamen in einem DBFS-Verzeichnis auf und gibt ein neues FlowFile mit dem Dateinamen aus. |
|
Ruft eine Liste von Dateien aus Dropbox ab (Verknüpfungen werden ignoriert). |
||
Startet einen FTP-Server, der auf dem angegebenen Port lauscht und eingehende Dateien in FlowFiles umwandelt. |
||
Startet einen HTTP-Server und lauscht auf einem bestimmten Basispfad, um eingehende Anfragen in FlowFiles umzuwandeln. |
||
Sammelt OpenTelemetry-Meldungen über HTTP oder gRPC. |
||
Ruft Echtzeit-Meldungen oder Slack-Befehle aus einer oder mehreren Slack-Konversationen ab. |
||
Hört auf Syslog-Meldungen, die über TCP oder UDP an einen bestimmten Port gesendet werden. |
||
Lauscht auf eingehende TCP-Verbindungen und liest Daten von jeder Verbindung, wobei ein Zeilentrenner als Meldungstrennzeichen verwendet wird. |
||
Überwacht einen bestimmten Port auf Datagramm-Pakete. |
||
Lauscht auf einem bestimmten Port auf Datagramm-Pakete und liest den Inhalt jedes Datagramms mit dem konfigurierten Record Reader. |
||
Fungiert als Endpunkt des WebSocket-Servers, um Client-Verbindungen zu akzeptieren. |
||
Ruft eine Liste der Dateien aus dem Eingabeverzeichnis ab. |
||
Listet die Dateien auf, die sich auf einem FTP-Server befinden. |
||
Ruft eine Liste von Objekten aus einem GCS-Bucket ab. |
||
Listet konkrete Dateien (Verknüpfungen werden ignoriert) in einem Google Drive-Ordner auf. |
||
Snowflake |
Listet alle Dateien und Ordner in einem bestimmten Google Drive auf. |
|
Snowflake |
Listet alle Gruppen für eine bestimmte Domäne in Google Workspace auf. |
|
Snowflake |
Ruft Daten aus HubSpot für bestimmte Objekttypen ab und generiert pro aufgelistetem Objekt ein FlowFile mit den entsprechenden Metadaten als FlowFile-Attribute. |
|
Snowflake |
Listet Tabellen aus Microsoft Dataverse-Umgebungen auf. |
|
Ruft eine Liste von Objekten aus einem S3-Bucket ab. |
||
Snowflake |
Listet die verfügbaren Datenfreigaben in der Organisation auf, auf die der identifizierte Benutzer zugreifen kann. |
|
Snowflake |
Liste der verfügbaren Objekte in der Organisation, die dem identifizierten Benutzer zur Verfügung stehen. |
|
Listet die Dateien auf, die sich auf einem SFTP-Server befinden. |
||
Snowflake |
Sendet ein FlowFile für jedes Laufwerk, das in der angegebenen SharePoint-Website vorhanden ist. |
|
Snowflake |
Listet alle SharePoint Standortgruppen auf, die auf einem bestimmten SharePoint-Standort verfügbar sind. |
|
Listet konkrete Dateien auf, die über das SMB-Protokoll freigegeben wurden. |
||
Snowflake |
Holt alle Quelltabellennamen und gleicht sie mit einer der möglichen Konfigurationen ab:- regexp expression e. |
|
Snowflake |
Listet die Dateinamen in einem Unity Catalog-Verzeichnis auf und gibt ein neues FlowFile mit dem Dateinamen aus. |
|
Gibt die Attribute des FlowFile gemäß dem angegebenen Protokolliergrad aus. |
||
Gibt eine Protokollmeldung gemäß dem angegebenen Protokolliergrad aus. |
||
Lookup von Attributen aus einem Lookup-Service |
||
Extrahiert ein Feld oder mehrere Felder aus einem Datensatz und sucht in einem LookupService nach einem Wert für diese Felder. |
M¶
Prozessor |
Beschreibung |
|
---|---|---|
Führt eine Gruppe von FlowFiles auf der Grundlage einer benutzerdefinierten Strategie zusammen und verpackt sie in einem einzigen FlowFile. |
||
Dieser Prozessor fügt mehrere datensatzorientierte FlowFiles zu einem einzigen FlowFile zusammen, der alle Datensätze der Eingabe-FlowFiles enthält. |
||
Snowflake |
Löst eine Operation zur Zusammenführung für Änderungen von der Journaltabelle zu einer Zieltabelle in Snowflake aus. |
|
Bytebereich am Anfang und Ende oder den gesamten Inhalt einer Binärdatei verwerfen. |
||
Ändert den Komprimierungsalgorithmus, mit dem der Inhalt eines FlowFile komprimiert wird, indem er den Inhalt von FlowFiles mit einem vom Benutzer angegebenen Komprimierungsalgorithmus dekomprimiert und den Inhalt mit den angegebenen Komprimierungsformateigenschaften neu komprimiert. |
||
Überwacht den Datenfluss auf Aktivität und sendet eine Meldung, wenn der Datenfluss für einen bestimmten Zeitraum keine Daten empfangen hat, sowie erneut, wenn die Aktivität des Datenflusses wiederhergestellt ist. |
||
Verschiebt Inhalte innerhalb eines Azure Data Lake Storage Gen 2. |
N¶
Prozessor |
Beschreibung |
|
---|---|---|
Speichert einen Freigabesignalbezeichner im verteilten Cache, optional zusammen mit den Attributen von FlowFile. |
O¶
Prozessor |
Beschreibung |
|
---|---|---|
Snowflake |
Transkribiert Audio in englischen Text. |
P¶
Prozessor |
Beschreibung |
|
---|---|---|
Dieser Prozessor verpackt die Attribute und Inhalte des FlowFile in ein Ausgabe-FlowFile, das aus NiFi exportiert und wieder in NiFi importiert werden kann, wobei die ursprünglichen Attribute und Inhalte erhalten bleiben. |
||
Ein Prozessor, mit dem der Benutzer eine paginierte Abfrage (mit Aggregationen) ausführen kann, die mit Elasticsearch JSON DSL geschrieben wurde. |
||
Analysiert den Inhalt einer Windows-Ereignisprotokolldatei (evtx) und schreibt die resultierende XML-Datei in dasFlowFile |
||
Snowflake |
Prozessor, der für das Parsen von Excel-Zellreferenzformeln zuständig ist. |
|
Versucht, den Inhalt einer Syslog-Meldung in Übereinstimmung mit den Formaten RFC5424 und RFC3164 zu parsen und fügt dem FlowFile Attribute für jeden Teil der Syslog-Meldung hinzu. |
||
Versucht, den Inhalt einer gut geformten Syslog-Meldung gemäß dem RFC5424-Format zu analysieren und fügt dem FlowFile für jeden Teil der Syslog-Meldung, Attribute hinzu, einschließlich der strukturierten Daten. |
||
Teilt oder partitioniert datensatzorientierte Daten basierend auf den konfigurierten Feldern in den Daten. |
||
Snowflake |
Führt eine optische Zeichenerkennung (OCR) auf PDF-Dokumenten durch und verwendet dabei die Funktionen von Snowflake Cortex ML. |
|
Snowflake |
Akzeptiert eine Liste vollqualifizierter Tabellennamen und ermittelt, ob eine Tabelle: - neu ist (nicht repliziert, aber in der Quelle hinzugefügt wurde) - existiert (repliziert und in der Quelle vorhanden) - veraltet ist (repliziert, aber in der Quelle nicht mehr vorhanden). Die Konfiguration wird als FlowFile-Attribut übergeben. |
|
Snowflake |
Sendet eine Eingabeaufforderung an Anthropic und schreibt die Antwort entweder als FlowFile-Attribut oder in den Inhalt des eingehenden FlowFile. |
|
Snowflake |
Sendet eine Eingabeaufforderung an den OpenAI-Dienst von Azure und schreibt die Antwort entweder als FlowFile-Attribut oder in den Inhalt des eingehenden FlowFile. |
|
Snowflake |
Dieser Prozessor sendet eine benutzerdefinierte Eingabeaufforderung an ein Large Language Model (LLM), das darauf antwortet. |
|
Snowflake |
Sendet eine Eingabeaufforderung an OpenAI und schreibt die Antwort entweder als FlowFile-Attribut oder in den Inhalt des eingehenden FlowFile. |
|
Snowflake |
Sendet eine Eingabeaufforderung an Snowflake Cortex und schreibt die Antwort entweder als FlowFile-Attribut oder in den Inhalt des eingehenden FlowFile. |
|
Snowflake |
Sendet eine Eingabeaufforderung an VertexAI und schreibt die Antwort entweder als FlowFile-Attribut oder in den Inhalt des eingehenden FlowFile. |
|
Erzeugt eine AMQP-Meldung aus dem Inhalt eines FlowFile und sendet die Meldung an eine AMQP-Börse. |
||
Veröffentlichen Sie den Inhalt des eingehenden FlowFile im konfigurierten Google Cloud PubSub-Thema. |
||
Erzeugt eine JMS-Meldung aus dem Inhalt eines FlowFile und sendet sie als JMS BytesMessage oder TextMessage an ein JMS-Ziel (Warteschlange oder Thema). |
||
Sendet den Inhalt eines FlowFile entweder als Meldung oder als einzelne Datensätze an Apache Kafka unter Verwendung der Kafka Producer-API. |
||
Snowflake |
Sendet den Inhalt eines FlowFile entweder als Meldung oder als einzelne Datensätze an Apache Kafka unter Verwendung der Kafka Producer-API. |
|
Veröffentlict eine Meldung in einem MQTT-Thema. |
||
Versendet eine Meldung an den angegebenen Slack-Kanal. |
||
Legt Inhalte in einem Blob auf Azure Blob Storage ab. |
||
Dieser Prozessor ist ein datensatzbasierter Prozessor zum Einfügen von Daten in eine Cosmos-DB mit der Core SQL-API. |
||
Fungiert als Azure Data Explorer-Senke, der FlowFiles an den angegebenen Endpunkt sendet. |
||
Schreibt den Inhalt eines FlowFile als Datei auf Azure Data Lake Storage Gen 2 |
||
FlowFile Inhalte an Azure Event Hubs senden |
||
Schreibt den Inhalt der eingehenden FlowFiles in den konfigurierten Azure Queue Storage. |
||
Schreibt den Inhalt eines FlowFile in eine Google BigQuery-Tabelle. |
||
Legt den Inhalt in einem Box-Ordner ab. |
||
Veröffenlicht Metriken in Amazon CloudWatch. |
||
Der PutDatabaseRecord-Prozesser verwendet einen angegebenen RecordReader, um (möglicherweise mehrere) Datensätze aus einem eingehenden FlowFile einzugeben. |
||
Snowflake |
Sendet eine SQL-Ausführung mit der Databricks REST-API, und schreiben Sie die JSON-Antwort in den FlowFile-Inhalt. |
|
Snowflake |
Schreibt FlowFile-Inhalt in DBFS. |
|
Ruft den Inhalt eines FlowFile ab und speichert ihn in einem verteilten Map-Cache unter Verwendung eines Cache-Schlüssels, der aus den Attributen des FlowFile berechnet wird. |
||
Legt den Inhalt in einem Dropbox-Ordner ab. |
||
Legt ein Dokument aus DynamoDB basierend auf einem Hashwert und einem Bereichsschlüssel an. |
||
Fügt Elemente auf der Grundlage von datensatzorientierten Daten in DynamoDB ein. |
||
Ein Elasticsearch-Put-Prozessor, der die offiziellen Elastic REST-Clientbibliotheken verwendet. |
||
Ein datensatzbasierter Elasticsearch-Put-Prozessor, der die offiziellen Elastic REST-Client-Bibliotheken verwendet. |
||
Sendet eine E-Mail an die konfigurierten Empfänger für jedes eingehende FlowFile. |
||
Schreibt den Inhalt eines FlowFile in das lokale Dateisystem. |
||
Sendet FlowFiles an einen FTP-Server |
||
Schreibt den Inhalt eines FlowFile als Objekt in einen Google Cloud Storage. |
||
Schreibt den Inhalt eines FlowFile als Datei in Google Drive. |
||
Schreibt eine Datei in einen GridFS-Bucket. |
||
Snowflake |
Ein HubSpot Objekt upserten. |
|
Snowflake |
Speichert Datensätze in Iceberg mit einem konfigurierbaren Katalog zur Verwaltung von Namespaces und Tabellen. |
|
Sendet den Inhalt an einen angegebenen Amazon Kinesis Firehose. |
||
Sendet den Inhalt an ein angegebenes Amazon Kinesis. |
||
Sendet den Inhalt an eine angegebene Amazon Lambda-Funktion. |
||
Schreibt den Inhalt eines FlowFile in MongoDB |
||
Schreibt den Inhalt eines FlowFile nach MongoDB als Bulk-Update |
||
Dieser Prozessor ist ein datensatzbasiert Prozessor zum Einfügen/Upload von Daten in MongoDB. |
||
Der PutRecord-Prozessor verwendet einen angegebene RecordReader, um (möglicherweise mehrere) Datensätze aus einem eingehenden FlowFile einzugeben, und sendet es an ein Ziel, das durch einen Record Destination Service (z. B. |
||
Speichert Datensatzfelddaten unter Verwendung eines angegebenen Hashwerts in Redis, der durch einen RecordPath zu einem Feld in jedem Datensatz bestimmt wird, das den Hashwert enthält. |
||
Schreibt den Inhalt eines FlowFile als S3-Objekt in einen Amazon S3 Bucket. |
||
Erzeugt neue Datensätze für das angegebene Salesforce-sObject. |
||
Sendet FlowFiles an einen SFTP-Server |
||
Schreibt den Inhalt eines FlowFile in ein Samba-Netzwerkverzeichnis. |
||
Snowflake |
Legt Dateien in einem internen Stagingbereich von Snowflake ab. |
|
Snowflake |
Streamt Datensätze in eine Snowflake-Tabelle. |
|
Sendet den Inhalt eines FlowFile als Benachrichtigung an den Amazon Simple Notification Service |
||
Sendet Protokolle an Splunk Enterprise über TCP, TCP + TLS/SSL, oder UDP. |
||
Sendet den Inhalt des FlowFile über HTTP oder HTTPS an den angegebenen Splunk-Server. |
||
Führt einen SQL UPDATE- oder INSERT-Befehl aus. |
||
Veröffentlichen einer Meldung in einer Amazon Simple Queuing Service-Warteschlange |
||
Sendet Syslog-Meldungen über TCP oder UDP an einen bestimmten Host und Port. |
||
Sendet serialisierte FlowFiles oder Datensätze über TCP an ein konfigurierbares Ziel mit optionaler Unterstützung für TLS |
||
Der PutUDP-Prozessor empfängt ein FlowFile und verpackt den FlowFile-Inhalt in ein einzelnes UDP-Datagramm-Paket, das dann an den konfigurierten UDP-Server übertragen wird. |
||
Snowflake |
Schreibt FlowFile-Inhalte mit einer maximalen Größe von 5 GiB in Unity Catalog. |
|
Snowflake |
Generiert ein JSON-Dokument und laden Sie es auf den Upload-Endpunkt von Vectara hoch. |
|
Snowflake |
Lädt einen FlowFile-Inhalt auf den Indexendpunkt von Vectara hoch. |
|
Sendet Meldungen an einen WebSocket-Remote-Endpunkt unter Verwendung einer WebSocket-Sitzung, die entweder von ListenWebSocket oder ConnectWebSocket aufgebaut wird. |
||
Erstellt Zendesk-Tickets mit der Zendesk-API. |
Q¶
Prozessor |
Beschreibung |
|
---|---|---|
Fragt von Azure Data Explorer und Streaming von JSON-Ergebnissen zu den Ausgabe-FlowFiles ab. |
||
Erzeugt eine SQL-Select-Abfrage oder verwendet eine bereitgestellte Anweisung und führt sie aus, um alle Zeilen abzurufen, deren Werte in der/den angegebenen Maximalwert-Spalte(n) größer sind als die zuvor angezeigten Maximalwerte. |
||
Erzeugt eine SQL-Select-Abfrage oder verwendet eine bereitgestellte Anweisung und führt sie aus, um alle Zeilen abzurufen, deren Werte in der/den angegebenen Maximalwert-Spalte(n) größer sind als die zuvor angezeigten Maximalwerte. |
||
Snowflake |
Fragt eine bestimmte Sammlung in einer Milvus-Datenbank mithilfe von Vektoren ab. |
|
Snowflake |
Fragt Pinecone nach Vektoren ab, die dem Eingabevektor ähnlich sind, oder ruft einen Vektor über ID ab. |
|
Wertet eine oder mehrere SQL-Abfragen anhand des Inhalts eines FlowFile aus. |
||
Ruft Datensätze aus einem Salesforce sObject ab. |
||
Fragt den Splunk-Server ab, um den Status der Indizierungsbestätigung abzurufen. |
R¶
Prozessor |
Beschreibung |
|
---|---|---|
Ändert den Inhalt eines FlowFile, das aufzeichnungsorientierte Daten enthält (z. |
||
Benennt ein oder mehrere Felder in jedem Datensatz eines FlowFile um. |
||
Aktualisiert den Inhalt eines FlowFile, indem nach einem Textwert im FlowFile-Inhalt gesucht wird (über reguläre Ausdrücke/Regex oder einen literalen Wert) und der Abschnitt des Inhalts, der übereinstimmt, durch einen alternativen Wert ersetzt wird. |
||
Aktualisiert den Inhalt eines FlowFile, indem ein regulärer Ausdruck darauf angewendet wird und der Teil des Inhalts, der dem regulären Ausdruck entspricht, durch einen alternativen Wert ersetzt wird, der in einer Zuordnungsdatei angegeben ist. |
||
FlowFiles, die an diesen Prozessor übergeben werden, haben einen „Retry Attribute“-Wert, der mit einem konfigurierten „Maximum Retries“-Wert verglichen wird. |
||
Weiterleitung von FlowFiles auf der Grundlage von Attributen unter Verwendung der Attribute Expression Language |
||
Wendet reguläre Ausdrücke auf den Inhalt eines FlowFile an und leitet eine Kopie des FlowFile an jedes Ziel weiter, dessen regulärer Ausdruck passt. |
||
Routing von Textdaten auf der Grundlage einer Reihe von benutzerdefinierten Regeln. |
||
Snowflake |
Löst einen vordefinierten Databricks-Job mit benutzerdefinierten Parametern aus. |
|
Ein Prozessor, der bei jedem Empfang eines FlowFile eine Aggregationsabfrage durchführt. |
S¶
Prozessor |
Beschreibung |
|
---|---|---|
Nimmt eine Stichprobe der Datensätze eines FlowFile anhand einer festgelegten Stichprobenstrategie (z. B. Reservoir Sampling). |
||
Scannt die angegebenen Attribute von FlowFiles und überprüft, ob einer ihrer Werte im angegebenen Begriffswörterbuch vorhanden ist. |
||
Durchsucht den Inhalt von FlowFiles nach Begriffen, die in einem vom Benutzer bereitgestellten Wörterbuch enthalten sind. |
||
Dieser Prozessor bietet die Möglichkeit, Datensätze aus FlowFiles herauszufiltern, indem er das vom Benutzer bereitgestellte Skript verwendet. |
||
Empfängt datensatzorientierte Daten (i. |
||
Bietet die Möglichkeit, ein einfaches Skript für jeden Datensatz in einem eingehenden FlowFile zu bewerten. |
||
Dieser Prozessor bietet die Möglichkeit, Datensätze in FlowFiles mit dem vom Benutzer bereitgestellten Skript zu überprüfen. |
||
Ein Prozessor, mit dem der Benutzer wiederholt eine paginierte Abfrage (mit Aggregationen) ausführen kann, die mit Elasticsearch JSON DSL geschrieben wurde. |
||
Segmentiert ein FlowFile in mehrere kleinere Segmente an Byte-Grenzen. |
||
Inhalte mit OpenPGP Private Keys signieren |
||
Snowflake |
Prüft, ob der Hashwert des FlowFile(der als FlowFile-Attribut angegeben wird) bereits in einer Snowflake-Tabelle enthalten ist und leitet das FlowFile bei einem Treffer an „duplicate“, bei keinem Treffer an „distinct“ und bei Fehlern an „failure“ weiter. |
|
Teilt eine binär codierte Avro-Datendatei basierend auf der konfigurierten Ausgabegröße in kleinere Dateien auf. |
||
Teilt eingehende FlowFiles nach einer angegebenen Bytefolge auf |
||
Dieser Prozessor teilt eine Microsoft Excel-Tabelle mit mehreren Blättern in mehrere Microsoft Excel-Tabellen auf, wobei jedes Blatt aus der Originaldatei in eine einzelne Tabelle in einem eigenen FlowFile konvertiert wird. |
||
Teilt eine JSON-Datei in mehrere, separate FlowFiles für ein Array-Element, das durch einen JsonPath-Ausdruck angegeben wird. |
||
Teilt ein Eingabe-FlowFile, das in einem datensatzorientierten Datenformat vorliegt, in mehrere kleinere FlowFiles. |
||
Teilt eine Textdatei in mehrere kleinere Textdateien an Zeilengrenzen auf, die durch die maximale Anzahl von Zeilen oder die Gesamtgröße des Fragments begrenzt sind. |
||
Teilt eine XML-Datei in mehrere separate FlowFiles auf, die jeweils ein untergeordnetes Element oder einen Nachfolgeelement des ursprünglichen Wurzelelements enthalten. |
||
Löst einen AWS-Polly-Job aus. |
||
Löst einen AWS-Textract-Job aus. |
||
Lösteinen AWS Transcribe-Job aus. |
||
Löst einen AWS-Translate-Job aus. |
||
Triggert eine Vision-Operation bei der Dateieingabe. |
||
Triggert eine Vision-Operation bei der Bildeingabe. |
||
Snowflake |
Übermittelt einen Abfragejob an Salesforce unter Verwendung der Funktion Bulk-API 2. |
|
Snowflake |
Dieser Prozessor verwendet ein Large Language Model (LLM), um den Inhalt eines FlowFile zusammenzufassen. |
T¶
Prozessor |
Beschreibung |
|
---|---|---|
Fügt ein Tag zu einem Amazon S3-Objekt hinzu oder aktualisiert es. |
||
„Hängt“ eine Datei oder eine Liste von Dateien an und nimmt Daten aus der Datei auf, während diese in die Datei geschrieben werden. |
||
Wendet die bereitgestellte XSLT-Datei auf die Nutzdaten von FlowFile XML an. |
U¶
Prozessor |
Beschreibung |
|
---|---|---|
Entpackt den Inhalt von FlowFiles, die mit einem von mehreren verschiedenen Verpackungsformaten verpackt wurden, und gibt dabei ein bis mehrere FlowFiles für jedes Eingabe-FlowFile aus. |
||
Aktualisiert die Attribute für ein FlowFile unter Verwendung der Attribute Expression Language und/oder löscht die Attribute auf der Grundlage eines regulären Ausdrucks. |
||
Aktualisiert die Werte der Metadatenvorlage für eine Box-Datei anhand des Datensatzes im angegebenen FlowFile. |
||
Aktualisieren Sie Dokumente in einem Elasticsearch-Index mithilfe einer Abfrage. |
||
Dieser Prozessor ermöglicht es Benutzern, bestimmte Zähler und Schlüsselpunkte in ihrem Ablauf festzulegen. |
||
Dieser Prozessor verwendet eine JDBC-Verbindung und eingehende Datensätze, um alle Änderungen in der Datenbanktabelle zu erzeugen, die zur Unterstützung der eingehenden Datensätze erforderlich sind. |
||
Aktualisiert den Inhalt eines FlowFile, das datensatzorientierte Daten enthält (i. |
||
Snowflake |
Aktualisiert die Definition einer Snowflake-Tabelle auf der Grundlage des im eingehenden FlowFile angegebenen Schemas. |
|
Snowflake |
Aktualisiert die Definition einer Snowflake Iceberg-Tabelle. |
|
Snowflake |
Aktualisiert den Status einer Tabelle im Tabellenstatusdienst. |
|
Snowflake |
Fügt für eine bestimmte Sammlung Vektoren in die Milvus-Datenbank ein |
|
Snowflake |
Veröffentlicht Vektoren, einschließlich Metadaten und optional Text, in einem Pinecone-Index. |
|
Snowflake |
Fügt die Datensätze aus dem eingehenden FlowFile in Salesforce ein |
V¶
Prozessor |
Beschreibung |
|
---|---|---|
Überprüft den Inhalt von FlowFiles oder einen FlowFile Attributwert anhand eines vom Benutzer angegebenen CSV-Schemas. |
||
Validiert den Inhalt von FlowFiles anhand eines konfigurierbaren JSON-Schemas. |
||
Überprüft die Datensätze eines eingehenden FlowFile anhand eines bestimmten Schemas. |
||
Validiert in einem FlowFile enthaltenes XML. |
||
Berechnet einen Message Authentication Code unter Verwendung des bereitgestellten Secret Key und vergleicht ihn mit der bereitgestellten MAC-Eigenschaft. |
||
Überprüft Signaturen mit OpenPGP Public Keys |
W¶
Prozessor |
Beschreibung |
|
---|---|---|
Leitet die FlowFiles an die Beziehung „wait“ weiter, bis ein passendes Freigabesignal von einem entsprechenden Notify-Prozessor im verteilten Cache gespeichert wird. |
||
Snowflake |
Blockiert eingehende FlowFiles solange, bis der entsprechende Tabellenstatus nicht gleich dem akzeptierten Status ist. |