FetchTableSnapshot 2025.5.31.15

バンドル

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

説明

データベースからテーブルのスナップショットを取得します。スナップショットは、テーブルのプライマリキー列を使用して、バッチで行を取得するために、インクリメンタルに取得されます。プライマリ・キーのないテーブルの複製はサポートされていません。スナップショットは、指定された Record Writer 形式の FlowFile に書き込まれます。入力 FlowFile は、次の形式のテーブルスキーマの JSON 表現で構成されることが期待されます:{ "columns": [{ "name": "<column name>", "type": "<column type>" }, { "name": "<column name>", "type": "<column type>" }, ... ], "primaryKeys": ["<name of first primary key column>", "<name of second primary key column>", ...]}スキーマで指定された列のみがテーブルから取得されます。

タグ

データベース、取得、rdbms、スナップショット、Snowflake、テーブル

入力要件

REQUIRED

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

false

プロパティ

プロパティ

説明

接続プール

データベーススナップショットの取得に使用する接続プール。

フェッチサイズ

一度にメモリにロードされる行の最大数

JDBC ドライバー 所在地

JAR ドライバーとその依存関係 (もしあれば) を含むファイル/フォルダおよび/または URLs のカンマ区切りリスト。例えば、'/var/tmp/postgresql-java-client-42.7.5.jar' です。

最大バッチサイズ

バッチで取得する行の最大数。

Record Writer

取得したスナップショットの書き込みに使用するRecord Writer

スキーマ名

以下からスナップショットを取得するスキーマ名。

テーブル名

以下からスナップショットを取得するテーブル名。

リレーションシップ

名前

説明

complete

スナップショットが完了すると、元の FlowFile はこのリレーションシップにルーティングされます。

failure

FlowFile で表されるテーブルからデータを取得できない場合、 FlowFile はこのリレーションシップにルーティングされます。

リトライ可能な失敗

FlowFile で表されるテーブルからデータを取得できないが、将来的に取得できるようになると予想される場合、 FlowFile はこのリレーションシップにルーティングされます。

rows

スナップショットが FlowFile で表されるテーブルから正常に取得されると、行はこのリレーションシップにルーティングされます。

属性の書き込み

名前

説明

snapshot.complete

スナップショットが完了したかどうかを示します。

rows.total.fetched

テーブルに対して取得された行の総数

rows.delta.fetched

最後の反復でテーブルに取得された行数

start.row.index

0から始まる、指定された反復のスナップショット内の最初の行のインデックス。

最終行インデックス

0から始まる、与えられた反復のスナップショット内の最後の行のインデックス。

取得・デルタ・タイム (ミリ単位)

最後の反復で行を取得するのにかかった時間 (ミリ秒単位)

取得の合計時間 (ミリ単位)

行の取得にかかった時間 (ミリ秒単位)