ConsumeSnowflakeStream 2025.10.2.19¶

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 dieser Prozessor verwendet wird. Der Prozessor wird den Stream verwenden und die Datensätze unter Verwendung des angegebenen Record Writer in das FlowFile schreiben. Der Prozessor fügt auch ein Attribut mit dem Namen des Streams zum FlowFile hinzu. Der Prozessor funktioniert nicht, wenn der Stream veraltet ist. Stattdessen wird eine Fehlermeldung protokolliert und die Verarbeitung abgebrochen. Der veraltete Stream muss in der Datenbank neu erstellt werden. Nachdem der Stream in der Datenbank neu erstellt wurde, wird der Prozessor weiter CDC-Datensätze lesen und verarbeiten. Weitere Informationen zu Snowflake Streams finden Sie in der <a href=“https://docs.snowflake.com/en/user-guide/streams-intro“>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