データベース ClickPipe を再同期する

データベース ClickPipe を再同期するためのドキュメント

​

再同期では何が行われますか？

再同期では、次の操作がこの順序で実行されます。

1. 既存の ClickPipe は削除され、新しい「再同期」ClickPipe が起動されます。そのため、再同期を行うと、ソーステーブルの構造変更も反映されます。
2. 再同期 ClickPipe は、元のテーブルと同じ名前で、末尾に _resync 接尾辞が付いた新しい宛先テーブル群を作成します (または置き換えます) 。
3. _resync テーブルに対して初期ロードが実行されます。
4. その後、_resync テーブルが元のテーブルと入れ替えられます。入れ替え前に、論理削除された行が元のテーブルから _resync テーブルに移されます。

元の ClickPipe の設定はすべて、再同期 ClickPipe に引き継がれます。元の ClickPipe の統計情報は UI 上でクリアされます。

​

ClickPipe を再同期するユースケース

想定されるシナリオは次のとおりです。

1. ソーステーブルに大規模なスキーマ変更を加える必要があり、その結果、既存の ClickPipe が使えなくなって再開が必要になる場合があります。その場合は、変更後に 再同期 をクリックするだけです。
2. 特に ClickHouse では、ターゲットテーブルの ORDER BY キーを変更する必要がある場合があります。再同期 を実行すると、適切なソートキーを持つ新しいテーブルにデータを再投入できます。
3. ClickPipe の replication slot が無効化された場合、再同期 によって新しい ClickPipe と、ソースデータベース上の新しい replication slot が作成されます。

再同期は複数回実行できますが、実行のたびに並列スレッドによる初期ロードが発生するため、 再同期時はソースデータベースへの負荷を考慮してください。

​

ClickPipe 再同期ガイド

1. Data Sources タブで、再同期する Postgres ClickPipe をクリックします。
2. Settings タブを開きます。
3. 再同期 ボタンをクリックします。

4. 確認ダイアログが表示されるので、もう一度 再同期 をクリックします。
5. Metrics タブを開きます。
6. 5 秒ほどで (ページを更新した場合も) 、パイプのステータスが Setup または Snapshot になります。
7. 再同期の初期ロードは、Tables タブの Initial Load Stats セクションで確認できます。
8. 初期ロードが完了すると、パイプは _resync テーブルを元のテーブルとアトミックに入れ替えます。入れ替え中のステータスは 再同期 です。
9. 入れ替えが完了すると、パイプは Running 状態になり、有効な場合は CDC (変更データキャプチャ) を実行します。