このページは Cloud Translation API によって翻訳されました。

CDC テーブルを別のリージョンに移行する

このページでは、BigQuery への Datastream レプリケーションを設定したものの、宛先データセットを誤ったリージョンに構成したユースケースのベストプラクティスについて説明します。ソースデータベースから BigQuery にすべてのデータを再同期しなくても、データセットを別のリージョン（またはマルチリージョン）に移動したい場合があります。

準備

データを別のリージョンに移行することを開始する前に、次の点を考慮してください。

移行には時間がかかり、オペレーション中にストリームを一時的に一時停止する必要があります。データの完全性を維持するため、ストリームが一時停止されたときに、ソースデータベースで変更ログが保持される必要があります。ストリームの一時停止時間を見積もるには、データセット内の max_staleness の値と最長実行のマージオペレーションを組み合わせます。
- マージオペレーションの完了にかかる時間については、テーブルで推奨される max_staleness 値をご覧ください。
- データセット内の最大 max_staleness を見つけるには、テーブルの現在の max_staleness 値を特定するを参照し、特定のニーズに合わせてクエリを調整します。
- 推定される一時停止がソースデータベースでサポートするには過剰に長時間にわたる場合は、データセット内のテーブルの max_staleness の値を一時的に小さくすることを検討してください。
移行を実行するユーザーに、移行先リージョンに十分な BigQuery リソース（クエリ予約とバックグラウンド予約）があることを確認します。予約の詳細については、予約割り当てをご覧ください。
移行を実行するユーザーに、Identity and Access Management（IAM）コントロールや VPC Service Controls などこのオペレーションを実行するための十分な権限が付与されていることを確認します。

移行手順

データセットの移行を開始するには、BigQuery データレプリケーションを使用します。

Google Cloud コンソールで、[BigQuery Studio] ページに移動します。

BigQuery Studio に移動
新しいリージョンに BigQuery データセットのレプリカを作成します。
```
ALTER SCHEMA DATASET_NAME
ADD REPLICA 'NEW_REGION'
OPTIONS(location='NEW_REGION');
```
以下を置き換えます。
- DATASET_NAME: 作成するデータセットの名前。
- NEW_REGION: データセットを作成するリージョンの名前。例: region-us
移行の進行状況をモニタリングし、レプリカのコピーウォーターマークがプライマリの数分以内になるまで待ちます。このクエリを BigQuery INFORMATION_SCHEMA で実行して、移行の進行状況を確認できます。
```
SELECT
catalog_name as project_id,
schema_name as dataset_name,
replication_time as dataset_replica_staleness
FROM
'NEW_REGION'.INFORMATION_SCHEMA.SCHEMATA_REPLICAS
WHERE
catalog_name = PROJECT_ID
AND schema_name = DATASET_NAME
AND location = NEW_REGION;
```
次のように置き換えます。
- PROJECT_ID: 実際の Google Cloud プロジェクト ID。
- DATASET_NAME: データセット名。
- DATASET_REPLICA_STALENESS: 作成したデータセットレプリカ内のテーブルの鮮度構成。
- NEW_REGION: クラスタを作成したリージョン。
既存の Datastream ストリームを一時停止します。詳細については、ストリームを一時停止するをご覧ください。
ストリームがドレインされるまで待機し、ストリームが PAUSED 状態になった時刻をメモします。
テーブルの upsert_stream_apply_watermark を確認して、最新の CDC 変更が BigQuery テーブルに適用されていることを確認します。次のクエリを実行して、ウォーターマークのタイムスタンプがストリームが一時停止された時点から 10 分後であることを確認します。
```
SELECT table_name, upsert_stream_apply_watermark
FROM DATASET_NAME.INFORMATION_SCHEMA.TABLES
```
特定のテーブルに対してのみクエリを実行するには、次の WHERE 句を追加します。
```
WHERE table_name = 'TABLE_NAME'
```
以下を置き換えます。
- DATASET_NAME: データセット名。
- TABLE_NAME: 省略可。upsert_stream_apply_watermark を確認するテーブル。
ステップ 3 のクエリを使用して、新しいリージョンコピーウォーターマークがステップ 6 で取得した upsert_stream_apply_watermark より後であることを確認します。
必要に応じて、元のリージョンのプライマリデータセットの複数のテーブルと新しいリージョンのレプリカを手動により比較して、すべてのデータが正しくコピーされていることを確認します。
BigQuery Studio で次のコマンドを実行して、BigQuery データセットのレプリカを昇格させます。
```
ALTER SCHEMA DATASET_NAME
SET OPTIONS(primary_replica = 'NEW_REGION');
```
以下を置き換えます。
- DATASET_NAME: データセット名。
- NEW_REGION: クラスタを作成したリージョン。
必要に応じて、元のデータセット（現在はレプリカ）が不要になり、追加料金が発生しないようにする場合は、BigQuery Studio に移動して、元の BigQuery データセットを削除します。
```
ALTER SCHEMA DATASET_NAME DROP REPLICA IF EXISTS ORIGINAL_REGION;
```
以下を置き換えます。
- DATASET_NAME: 元のデータセットの名前。
- ORIGINAL_REGION: 元のデータセットのリージョン。
構成はまったく同じで、BigQuery の宛先ロケーションが異なる新しいストリームを作成します。
新しいストリームを開始します。

重複するイベントの複製を防ぐには、ストリームを特定の位置から開始します。
- MySQL ソースと Oracle ソースの場合: 元のストリームのログを調べて、ストリームが正常に読み取られた最後の位置を見つけることで、ログの位置を特定できます。特定の位置からストリームを開始する場合については、ストリームを管理するをご覧ください。
- PostgreSQL ソースの場合: 新しいストリームは、レプリケーションスロットの最初のログシーケンス番号（LSN）から変更の読み取りを開始します。元のストリームでこれらの変更の一部がすでに処理されている可能性があるため、レプリケーションスロットのポインタを Datastream が読み取った最後の LSN に手動で変更します。この LSN は、Datastream コンシューマのログで確認できます。
必要に応じて、元のストリームを削除します。

CDC テーブルを別のリージョンに移行する コレクションでコンテンツを整理 必要に応じて、コンテンツの保存と分類を行います。

準備

移行手順

CDC テーブルを別のリージョンに移行する