7.2. Debezium PostgreSQL コネクターの仕組み

ソースシグナリングチャネルを使用して増分スナップショットをトリガーする

1. SQL クエリーを送信し、アドホック増分スナップショット要求をシグナルテーブルに追加します。

   INSERT INTO <signalTable> (id, type, data) VALUES ('<id>', '<snapshotType>', '{"data-collections": ["<tableName>","<tableName>"],"type":"<snapshotType>","additional-condition":"<additional-condition>"}');

   Copy to Clipboard Toggle word wrap

   以下に例を示します。

   INSERT INTO myschema.debezium_signal (id, type, data) 

   1

   
   values ('ad-hoc-1',   

   2

   
       'execute-snapshot',  

   3

   
       '{"data-collections": ["schema1.table1", "schema2.table2"], 

   4

   
       "type":"incremental"}, 

   5

   
       "additional-condition":"color=blue"}'); 

   6

   Copy to Clipboard Toggle word wrap

   コマンドの id、type、および data パラメーターの値は、シグナルテーブルのフィールド に対応します。

   以下の表では、この例のパラメーターについて説明しています。

   Expand

   表7.3 シグナルテーブルに増分スナップショットシグナルを送信する SQL コマンドのフィールドの説明

   項目	値	説明
   1	myschema.debezium_signal	ソースデータベースにあるシグナルテーブルの完全修飾名を指定します。
   2	ad-hoc-1	id パラメーターは、シグナルリクエストの ID 識別子として割り当てられる任意の文字列を指定します。 この文字列を使用して、シグナルテーブルのエントリーへのログメッセージを特定します。Debezium はこの文字列を使用しません。代わりに、スナップショット作成中に、Debezium は独自の ID 文字列をウォーターマークシグナルとして生成します。
   3	execute-snapshot	type パラメーターを指定し、シグナルがトリガーする操作を指定します。
   4	data-collections	シグナルの data フィールドの必須コンポーネントで、スナップショットに含めるテーブル名の配列またはテーブル名と一致する正規表現を指定します。 この配列は、完全修飾名でテーブルをマッチさせる正規表現をリストアップします。signal.data.collection 設定プロパティーでコネクターのシグナリングテーブル名を指定するのと同じ形式を使用します。
   5	incremental	実行するスナップショット操作の種類指定するシグナルの data フィールドの任意のtype コンポーネント。 現在、唯一の有効なオプションはデフォルト値 incremental だけです。 値を指定しない場合には、コネクターは増分スナップショットを実行します。
   6	additional-condition	テーブルの内容のサブセットを取得するために、テーブルの列に基づいて条件を指定するオプションの文字列。additional-condition パラメーターの詳細は、additional-condition 付きのアドホック増分スナップショット を参照してください。

   Show more

ソースシグナリングチャネルを使用して増分スナップショットを停止する

1. SQL クエリーを送信して、シグナリングテーブルへのアドホックインクリメンタル スナップショットを停止します。

   INSERT INTO <signalTable> (id, type, data) values ('<id>', 'stop-snapshot', '{"data-collections": ["<tableName>","<tableName>"],"type":"incremental"}');

   Copy to Clipboard Toggle word wrap

   以下に例を示します。

   INSERT INTO myschema.debezium_signal (id, type, data) 

   1

   
   values ('ad-hoc-1',   

   2

   
       'stop-snapshot',  

   3

   
       '{"data-collections": ["schema1.table1", "schema2.table2"], 

   4

   
       "type":"incremental"}'); 

   5

   Copy to Clipboard Toggle word wrap

   signal コマンドの id、type、および data パラメーターの値は、シグナルテーブルのフィールド に対応します。

   以下の表では、この例のパラメーターについて説明しています。

   Expand

   表7.5 シグナリングテーブルに増分スナップショット停止信号を送信するための SQL コマンドのフィールドの説明

   項目	値	説明
   1	myschema.debezium_signal	ソースデータベースにあるシグナルテーブルの完全修飾名を指定します。
   2	ad-hoc-1	id パラメーターは、シグナルリクエストの ID 識別子として割り当てられる任意の文字列を指定します。 この文字列を使用して、シグナルテーブルのエントリーへのログメッセージを特定します。Debezium はこの文字列を使用しません。
   3	stop-snapshot	type パラメーターを指定し、シグナルがトリガーする操作を指定します。
   4	data-collections	シグナルの data フィールドのオプションコンポーネントで、スナップショットから削除するテーブル名の配列またはテーブル名とマッチする正規表現を指定します。 この配列は、完全修飾名でテーブルをマッチさせる正規表現をリストアップします。signal.data.collection 設定プロパティーでコネクターのシグナリングテーブル名を指定するのと同じ形式を使用します。data フィールドのこのコンポーネントを省略すると、シグナルは進行中の増分スナップショット全体を停止します。
   5	incremental	停止させるスナップショット操作の種類を指定する信号の data フィールドの必須コンポーネント。 現在、有効な唯一のオプションは incremental です。 type の値を指定しない場合、シグナルは増分スナップショットの停止に失敗します。

   Show more