UpdateSnowflakeStream 2025.10.2.19

バンドル

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

説明

設定された操作に基づいてストリームを作成、削除、交換することで、Snowflakeストリームを管理します。Snowflakeのストリームは、テーブルのデータ変更をキャプチャし、 DML の経時的な変更を追跡するために使用できます。

タグ

CDC、作成、ドロップ、プレビュー、置換、Snowflake、ストリーム、テーブル

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

接続プール

Snowflakeへの接続に使用する接続プール。

オブジェクト識別子の解決

ソースオブジェクト識別子(スキーマ、テーブル、列)がSnowflakeにどのように格納され、クエリされるかを制御します。この設定により、 SQL クエリで二重引用符を使用する必要があるかどうかが決まります。

スキーマ名

ストリームおよび/またはソーステーブルを含んでいるスキーマの名前

ソーステーブル名

ストリームのソーステーブルの名前

ストリーム作成パラメーター

CREATE STREAM ステートメントに含まれる追加のパラメーター。例:'APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE'

ストリーム名

作成、ドロップ、または置換するストリームの名前

更新タイプ

実行するストリーム操作のタイプ

リレーションシップ

名前

説明

failure

ストリーム操作が完了できない場合、受信 FlowFile はこのリレーションシップにルーティングされます

オブジェクトが見つかりません

指定されたストリームまたはソーステーブルが存在しない場合、受信 FlowFile はこのリレーションシップにルーティングされます。

success

受信 FlowFile は、ストリーム操作が正常に完了した後、このリレーションシップにルーティングされます。