ConsumeSnowflakeStream 2025.5.31.15¶

Bundle¶

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

Beschreibung¶

Ruft Daten aus einem Snowflake-Stream ab und schreibt sie in ein FlowFile. Der Stream muss in der Datenbank erstellt werden, bevor Sie diesen Prozessor verwenden. Der Prozessor empfängt den Stream und schreibt die Datensätze mit dem angegebenen Record Writer in das FlowFile. Der Prozessor fügt außerdem ein Attribut mit dem Namen des Streams in das FlowFile ein. Stattdessen wird eine Fehlermeldung protokolliert und die Verarbeitung gestoppt. Der veraltete Stream muss in der Datenbank neu erstellt werden. Nachdem der Stream in der Datenbank neu erstellt wurde, liest und verarbeitet der Prozessor weiterhin CDC-Datensätze. Weitere Informationen zu Snowflake-Streams finden Sie unter <a href=“https://docs.snowflake.com/en/user-guide/streams-intro“>in der Snowflake-Dokumentation</a>.

Tags¶

connection, database, jdbc, openflow, snowflake, stream, table, view

Eingabeanforderung¶

FORBIDDEN

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Max Chunk Size	Anzahl der Datensätze, die in ein einzelnes FlowFile geschrieben werden sollen. Dieser Wert kann leicht überschritten werden.
Record Writer	Der Record Writer, der für die Serialisierung von CDC-Daten verwendet wird
Snowflake Connection Service	Datenbankverbindungsdienst für den Zugriff auf Snowflake
Stream-Name	Der Name des Streams in der Datenbank

Beziehungen¶

Name	Beschreibung
success	Für FlowFiles mit Stream-CDC-Datensätzen

Schreibt Attribute¶

Name	Beschreibung
snowflake.stream.name	Name des Snowflake-Streams