CaptureChangeMySQL 2025.5.31.15¶

バンドル¶

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

説明¶

MySQL データベースから CDC イベントを読み込みます。プロセッサーはバイナリログファイルからイベントを継続的に読み込み、 TableStateService によって提供されたテーブルに関連するものをフィルターにかけ、残りを破棄します。プロセッサーは2タイプのフローファイルを出力します:- テーブルのスキーマ（初期スキーマと、スキーマ変更のたびに新しいスキーマ）を含む DDLs .-テーブルのデータの変更を示す記録を含む DMLs 。1つのフローファイルは、常に1つのテーブルに関連するデータを表します。スキーマを含む DDL は、 JSON オブジェクトとして、 FlowFile コンテンツに書き込まれます:{ "columns": [ { "name": "<columnName>", "type": "<snowflakeType>", "nullable": <true|false>, "scale": <scale>, "precision": <precision> }, ... ], "primaryKeys": ["<primaryKey1>", "<primaryKey2>", ...]} DML 記録を含む FlowFiles の構成:{ "primaryKeys": { "<column>": <value>, ... }, "payload": { "<column>": <value>, ... }, "metadata": { "<column>": <value>, ... }}

タグ¶

cdc, event, jdbc, mysql, sql

入力要件¶

FORBIDDEN

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

false

プロパティ¶

状態管理¶

リレーションシップ¶

属性の書き込み¶