ConsumeSnowflakeStream 2025.10.2.19¶

バンドル¶

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

説明¶

Snowflakeストリームからデータを取得し、 FlowFile に書き込みます。このプロセッサーを使用する前に、ストリームをデータベースに作成しておく必要があります。プロセッサーはストリームを消費し、指定されたRecord Writerを使用して FlowFile に記録を書き込みます。プロセッサーはまた、ストリームの名前を持つ属性を FlowFile に追加します。ストリームが古いと、プロセッサーは動作しません。その代わり、エラーメッセージを記録し、処理を停止します。古くなったストリームはデータベースで再作成される必要があります。ストリームがデータベースに再作成された後、プロセッサーは CDC 記録の読み取りと処理を続行します。Snowflakeストリームの詳細については、 <a href="https://docs.snowflake.com/ja/user-guide/streams-intro">Snowflakeドキュメント</a> をご参照ください。

タグ¶

接続、データベース、jdbc、オープンフロー、Snowflake、ストリーム、テーブル、表示

入力要件¶

FORBIDDEN

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

false

プロパティ¶

リレーションシップ¶

属性の書き込み¶