UpdateSnowflakeStream 2025.10.2.19¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Beschreibung¶

Verwaltet Snowflake Streams, indem es sie basierend auf dem konfigurierten Vorgang erstellt, löscht oder ersetzt. Streams in Snowflake erfassen Datenänderungen für Tabellen und können zur Nachverfolgung von DML-Änderungen im Laufe der Zeit verwendet werden.

Tags¶

cdc, erstellen, löschen, vorschau, ersetzen, snowflake, stream, tabelle

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Connection Pool	Der Verbindungspool, der für die Verbindung mit Snowflake verwendet wird
Auflösung des Objektbezeichners	Steuert, wie die Bezeichner der Quellobjekte (Schemas, Tabellen, Spalten) in Snowflake gespeichert und abgefragt werden. Diese Einstellung bestimmt, ob Sie in Ihren SQL-Abfragen doppelte Anführungszeichen verwenden müssen.
Schema Name	Der Name des Schemas, das den Stream und/oder die Quelltabelle enthält
Source Table Name	Der Name der Quelltabelle für den Stream
Parameter für die Stream-Erstellung	Zusätzliche Parameter, die in die CREATE STREAM-Anweisung aufgenommen werden sollen. Beispiel: ‚APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE‘
Stream-Name	Der Name des zu erstellenden, zu löschenden oder zu ersetzenden Streams
Aktualisierungstyp	Die Art des auszuführenden Stream-Vorgangs

Beziehungen¶

Name	Beschreibung
failure	Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn der Stream-Vorgang nicht abgeschlossen werden kann
object not found	Das eingehende FlowFile wird an diese Beziehung weitergeleitet, wenn der angegebene Stream oder die Quelltabelle nicht vorhanden ist.
success	Das eingehende FlowFile wird nach erfolgreichem Abschluss des Stream-Vorgangs an diese Beziehung weitergeleitet