このトピックでは、Data Transmission Service (DTS) を使用して ApsaraDB RDS for PostgreSQL インスタンス間で一方向のデータ同期を設定する方法について説明します。
前提条件
ソースとデスティネーションの ApsaraDB RDS for PostgreSQL インスタンスが作成されます。詳細については、「ApsaraDB RDS for PostgreSQL インスタンスを作成する」をご参照ください。
説明- 説明
詳細については、「データ同期シナリオの概要」をご参照ください。
ターゲットデータベースのバージョンは、ソースデータベースのバージョンと同じかそれ以上です。これにより、データベースの互換性が確保されます。ターゲットデータベースのバージョンがソースデータベースのバージョンよりも古い場合、データベースの互換性の問題が発生する可能性があります。
宛先 ApsaraDB RDS for PostgreSQL インスタンスの使用可能なストレージ容量は、ソース ApsaraDB RDS for PostgreSQL インスタンスのデータ総容量よりも大きくなっています。
使用方法
カテゴリ | 説明 |
ソース データベースの制限 |
説明 DTS を使用せずに作成したデータ同期タスクでデータを受信するターゲットテーブル([スキーマ同期] が [同期タイプ] パラメーターで選択されていない場合)では、テーブルとソースデータベースから同期されるテーブルに同じ PRIMARY KEY制約または NOT NULL UNIQUE制約があることを確認してください。そうでない場合、ターゲットデータベースに重複するデータレコードが含まれる可能性があります。 |
その他の制限 |
|
特別なケース |
|
課金
| 同期タイプ | タスク構成料金 |
| スキーマ同期と完全同期 | 無料。 |
| 増分同期 | 有料。詳細については、「課金概要」をご参照ください。 |
サポートされている同期トポロジ
一方向の 1 対 1 の同期
一方向の 1 対多同期
一方向カスケード同期
一方向の多対一同期
詳細については、「同期トポロジ」をご参照ください。
同期されるサポート対象オブジェクト
SCHEMA と TABLE。
説明PRIMARY KEY、UNIQUE KEY、FOREIGN KEY、データ型(組み込みデータ型)、および DEFAULT CONSTRAINT を含みます。
VIEW、PROCEDURE(PostgreSQL V11 以降)、FUNCTION、RULE、SEQUENCE、EXTENSION、TRIGGER、AGGREGATE、INDEX、OPERATOR、および DOMAIN。
同期可能な SQL 操作
操作タイプ | SQL ステートメント |
DML | INSERT、UPDATE、および DELETE |
DDL |
|
手順
次のいずれかの方法を使用して、[データ同期] ページに移動し、データ同期インスタンスが存在するリージョンを選択します。
DTS コンソール
DTS コンソール にログオンします。
左側のナビゲーションウィンドウで、データ同期 をクリックします。
ページの左上隅で、データ同期インスタンスが存在するリージョンを選択します。
DMS コンソール
説明DMS コンソールのモードとレイアウトによって、実際の操作は異なる場合があります。詳細については、「シンプルモード」と「DMS コンソールのレイアウトとスタイルをカスタマイズする」をご参照ください。
DMS コンソール にログオンします。
上部のナビゲーションバーで、[データ + AI] にポインターを移動し、 を選択します。
データ同期タスク の右側のドロップダウンリストから、データ同期インスタンスが存在するリージョンを選択します。
タスクの作成 をクリックして、タスク構成ページに移動します。
ソースデータベースとターゲットデータベースを構成します。次の表は、パラメーターについて説明しています。
警告ソースデータベースとターゲットデータベースを構成した後、ページに表示される [制限] をご確認ください。確認しないと、タスクが失敗したり、データの不整合が発生したりする可能性があります。
セクション
パラメーター
説明
N/A
タスク名
DTS タスクの名前。DTS はタスク名を自動的に生成します。タスクを識別しやすい説明的な名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
移行元データベース
データベースタイプ
ソース データベースのタイプです。[PostgreSQL] を選択します。
アクセス方法
ソースデータベースのアクセス方法。 [Alibaba Cloud インスタンス] を選択します。
インスタンスリージョン
ApsaraDB RDS for PostgreSQL インスタンスが存在するリージョン。
Alibaba Cloud アカウント間でデータを複製
In this example, a database of the current Alibaba Cloud account is used. Select ×。
インスタンス ID
ApsaraDB RDS for PostgreSQL インスタンスのソース ID。
データベース名
ApsaraDB RDS for PostgreSQL インスタンスのソースでオブジェクトが同期されるデータベースの名前。
データベースアカウント
ソース ApsaraDB RDS for PostgreSQL インスタンスのデータベースアカウント。データベースのオーナーである特権アカウントを指定します。ApsaraDB RDS for PostgreSQL インスタンスのアカウントを作成し、そのアカウントに権限を付与する方法の詳細については、「アカウントを作成する」および「データベースを作成する」をご参照ください。
説明ソースインスタンスが ApsaraDB RDS for PostgreSQL V9.4 インスタンスで、DML 操作のみを同期する場合、データベースアカウントには REPLICATION 権限のみが必要です。
データベースパスワード
データベースにアクセスするために使用するパスワード。
暗号化
ソースデータベースへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて、このパラメーターを構成できます。この例では、非暗号化 が選択されています。
ソースデータベースへの SSL 暗号化接続を確立するには、次の手順を実行します。SSL 暗号化 を選択し、必要に応じて CA 証明書、クライアント証明書、クライアント証明書の秘密鍵 をアップロードし、クライアント証明書の秘密鍵のパスワード を指定します。
説明自主管理 PostgreSQL データベースに対して、暗号化を SSL 暗号化 に設定した場合、CA 証明書 をアップロードする必要があります。
クライアント証明書を使用する場合は、クライアント証明書 と クライアント証明書の秘密鍵 をアップロードし、クライアント証明書の秘密鍵のパスワード を指定する必要があります。
ApsaraDB RDS for PostgreSQL インスタンスの SSL 暗号化を構成する方法については、「SSL 暗号化」をご参照ください。
移行先データベース
データベースタイプ
宛先データベースのタイプ。 [PostgreSQL] を選択します。
アクセス方法
接続先データベースのアクセス方法。 [Alibaba Cloud インスタンス] を選択します。
インスタンスリージョン
ApsaraDB RDS for PostgreSQL インスタンスが存在するリージョン。
インスタンス ID
ApsaraDB RDS for PostgreSQL インスタンスの宛先 ID。
データベース名
ApsaraDB RDS for PostgreSQL インスタンスの同期先データベースの名前。
データベースアカウント
宛先 ApsaraDB RDS for PostgreSQL インスタンスのデータベースアカウント。アカウントは、スキーマに対するオーナー権限を持っている必要があります。ApsaraDB RDS for PostgreSQL インスタンスのアカウントを作成し、アカウントに権限を付与する方法については、「アカウントを作成する」をご参照ください。
データベースパスワード
データベースにアクセスするために使用するパスワード。
暗号化
ソースデータベースへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて、このパラメーターを構成できます。この例では、非暗号化 が選択されています。
ソースデータベースへの SSL 暗号化接続を確立するには、次の手順を実行します。SSL 暗号化 を選択し、必要に応じて CA 証明書、クライアント証明書、クライアント証明書の秘密鍵 をアップロードし、クライアント証明書の秘密鍵のパスワード を指定します。
説明自主管理 PostgreSQL データベースの暗号化を SSL 暗号化 に設定する場合は、CA 証明書 をアップロードする必要があります。
クライアント証明書を使用する場合は、クライアント証明書 と クライアント証明書の秘密鍵 をアップロードし、クライアント証明書の秘密鍵のパスワード を指定する必要があります。
ApsaraDB RDS for PostgreSQL インスタンスの SSL 暗号化を構成する方法については、「SSL 暗号化」をご参照ください。
接続をテストして続行 をクリックします。
説明DTS サーバーの CIDR ブロックが、DTS サーバーからのアクセスを許可するために、ソースデータベースとターゲットデータベースのセキュリティ設定に自動または手動で追加できることを確認します。詳細については、「DTS サーバーの CIDR ブロックを追加する」をご参照ください。
ソースデータベースまたはターゲットデータベースが自己管理データベースであり、その アクセス方法 が Alibaba Cloud インスタンス に設定されていない場合は、接続テストDTS サーバーの CIDR ブロック ダイアログボックスで をクリックします。
同期するオブジェクトを構成します。
オブジェクト設定 ステップで、同期するオブジェクトを設定します。
パラメーター
説明
同期タイプ
同期タイプ。デフォルトでは、[増分データ同期] が選択されています。[スキーマ同期] と [フルデータ同期] も選択する必要があります。事前チェックが完了すると、DTS は選択したオブジェクトの既存データをソースデータベースからデスティネーションクラスターに同期します。既存データは、後続の増分同期の基礎となります。
説明[スキーマ同期] を選択すると、DTS は同期対象のテーブルのスキーマをソースデータベースからターゲットデータベースに同期します。スキーマには外部キーが含まれます。
同期トポロジ
この例では、一方向同期 が選択されています。
競合するテーブルの処理モード
エラーの事前チェックと報告: ターゲットデータベースにソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかを確認します。 ソースデータベースとターゲットデータベースに同じテーブル名のテーブルが含まれていない場合、事前チェックは成功です。 それ以外の場合、事前チェック中にエラーが返され、データ同期タスクを開始できません。
説明ソースデータベースとターゲットデータベースに同じ名前のテーブルが含まれており、ターゲットデータベース内のテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、ターゲットデータベースに同期されるテーブルの名前を変更できます。詳細については、「オブジェクト名をマップする」をご参照ください。
エラーを無視して続行: ソースデータベースとターゲットデータベースで同一のテーブル名が存在する場合の事前チェックをスキップします。
警告エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
ソースデータベースとターゲットデータベースのスキーマが同じで、ターゲットデータベースのデータレコードのプライマリキー値または一意のキー値がソースデータベースのデータレコードと同じである場合:
完全同期中は、DTS はデータレコードをターゲットデータベースに同期しません。ターゲットデータベース内の既存のデータレコードは保持されます。
増分データ同期中、DTS はデータレコードをターゲットデータベースに同期します。ターゲットデータベース内の既存のデータレコードは上書きされます。
ソースデータベースとターゲットデータベースのスキーマが異なる場合、データの初期化に失敗する可能性があります。この場合、一部の列のみが同期されるか、データ同期タスクが失敗します。注意して進めてください。
移行先インスタンスでのオブジェクト名の大文字化
宛先インスタンスにおけるデータベース名、テーブル名、および列名の大文字と小文字の区別。デフォルトでは、[DTS デフォルト ポリシー] が選択されています。ソースまたはターゲットデータベースでのオブジェクト名の大文字と小文字の区別と一致するように、他のオプションを選択できます。詳細については、「宛先インスタンスのオブジェクト名の大文字と小文字の指定」をご参照ください。
ソースオブジェクト
ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択し、
アイコンをクリックして、選択中のオブジェクト セクションにオブジェクトを追加します。説明スキーマまたはテーブルを同期対象のオブジェクトとして選択できます。テーブルを同期対象のオブジェクトとして選択した場合、DTS はビュー、トリガー、ストアドプロシージャなどの他のオブジェクトをターゲットデータベースに移行しません。
SERIAL データ型のテーブルを同期する場合、[スキーマ同期][同期の種類] として シーケンス を選択する場合は、またはスキーマ全体の同期も選択することをお勧めします。
選択中のオブジェクト
宛先インスタンスに同期するオブジェクトの名前を変更するには、選択中のオブジェクト セクションでオブジェクトを右クリックします。詳細については、「単一オブジェクトの名前をマップする」セクションのオブジェクト名のマッピングに関するトピックをご参照ください。
複数のオブジェクトの名前を一度に変更するには、一括編集 を 選択中のオブジェクト セクションの右上隅でクリックします。詳細については、「一度に複数のオブジェクト名をマップする」セクションのオブジェクト名マップのトピックをご参照ください。
説明特定のデータベースまたはテーブルで実行される SQL 操作を選択するには、[選択したオブジェクト] セクションでオブジェクトを右クリックします。表示されるダイアログボックスで、同期する SQL 操作を選択します。詳細については、このトピックの「同期できる SQL 操作」セクションをご参照ください。
データをフィルタリングするための WHERE 条件を指定するには、[選択したオブジェクト] セクションのテーブルを右クリックします。表示されるダイアログボックスで、条件を指定します。詳細については、「フィルター条件を設定する」をご参照ください。
オブジェクト名マッピング機能を使用してオブジェクトの名前を変更すると、そのオブジェクトに依存する他のオブジェクトの同期に失敗する可能性があります。
次へ:詳細設定 をクリックして、詳細設定を構成します。
パラメーター
説明
タスクのスケジュールに使用する専用クラスターの選択
デフォルトでは、専用クラスターを指定しない場合、DTS は共有クラスターにタスクをスケジュールします。データ同期タスクの安定性を向上させるには、専用クラスターを購入します。詳細については、「DTS 専用クラスターとは」をご参照ください。
失敗した接続の再試行時間
接続に失敗した場合のリトライ時間範囲。データ同期タスクの開始後にソースデータベースまたはターゲットデータベースへの接続に失敗した場合、DTS はこの時間範囲内で直ちに接続を再試行します。有効値: 10 ~ 1440。単位: 分。デフォルト値: 720。このパラメーターには 30 より大きい値を設定することをお勧めします。DTS が指定された時間範囲内にソースデータベースとターゲットデータベースに再接続した場合、DTS はデータ同期タスクを再開します。そうでない場合、データ同期タスクは失敗します。
説明複数のデータ同期タスクで同じソースまたはターゲットデータベースを指定し、それぞれに異なるリトライ時間範囲を設定した場合、最も短いリトライ時間範囲が優先されます。
DTS が接続をリトライすると、DTS インスタンスに対して課金されます。ビジネス要件に基づいてリトライ時間範囲を指定することをお勧めします。また、ソースインスタンスと宛先インスタンスが解放された後、できるだけ早く DTS インスタンスを解放することもできます。
移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。
その他の問題のリトライ時間範囲。たとえば、データ同期タスクの開始後に DDL または DML 操作が失敗した場合、DTS は指定された時間範囲内で操作をすぐにリトライします。有効値: 1 ~ 1440。単位: 分。デフォルト値: 10。このパラメーターは 10 より大きい値に設定することをお勧めします。指定された時間範囲内で失敗した操作が正常に実行された場合、DTS はデータ同期タスクを再開します。そうでない場合、データ同期タスクは失敗します。
重要移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。 パラメーターの値は、失敗した接続の再試行時間 パラメーターの値よりも小さくなければなりません。
完全移行率を制限するかどうか
完全同期中は、DTS はソースデータベースとターゲットデータベースの読み取りリソースと書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。ターゲットデータベースサーバーの負荷を軽減するために、完全同期タスクの1 秒あたりのソースデータベースのクエリ率 QPS、1 秒あたりの完全移行の行数 RPS、および1 秒あたりの完全移行データ量 (MB) BPS パラメーターを構成できます。
説明このパラメーターは、完全データ同期 が 同期タイプ パラメーターに選択されている場合にのみ構成できます。
増分同期率を制限するかどうか
増分データ同期の速度制限を有効にするかどうかを指定します。ビジネス要件に基づいて、増分データ同期の速度制限を有効にすることができます。速度制限を設定するには、1 秒あたりの増分同期の行数 RPS パラメーターと 1 秒あたりの増分同期データ量 (MB) BPS パラメーターを設定する必要があります。これにより、ターゲットデータベースサーバーの負荷が軽減されます。
環境タグ
DTS インスタンスを識別するために使用される環境タグ。ビジネス要件に基づいて環境タグを選択できます。この例では、このパラメーターを設定する必要はありません。
ETL の設定
抽出、変換、書き出し (ETL) 機能を有効にするかどうかを指定します。詳細については、「ETL とは」をご参照ください。有効な値:
[はい]: ETL 機能を設定します。コードエディタにデータ処理ステートメントを入力できます。詳細については、「データ移行タスクまたはデータ同期タスクで ETL を設定する」をご参照ください。
いいえ: ETL 機能は構成されません。
監視アラート
データ同期タスクのアラートを構成するかどうかを指定します。タスクが失敗した場合、または同期遅延が指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。有効な値:
いいえ: アラートは有効になりません。
はい: アラートを設定します。この場合、アラートのしきい値とアラート通知設定も構成する必要があります。詳細については、「DTS タスクの作成時にモニタリングとアラートを構成する」セクションの「モニタリングとアラートを構成する」トピックをご参照ください。
[次のステップ: データ検証] をクリックして、データ検証を設定します。
詳細については、「データ検証を設定する」をご参照ください。
タスク設定を保存し、事前チェックを実行します。
関連 API 操作を呼び出して DTS タスクを構成する際に指定するパラメーターを表示するには、 次:タスク設定の保存と事前チェック にポインターを移動し、OpenAPI パラメーターのプレビュー をクリックします。
パラメータを表示する必要がない場合、またはすでに表示した場合は、ページ下部にある 次:タスク設定の保存と事前チェック をクリックします。
説明データ同期タスクを開始する前に、DTS は事前チェックを実行します。タスクが事前チェックに合格した後でのみ、データ同期タスクを開始できます。
データ同期タスクが事前チェックに失敗した場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題をトラブルシューティングします。その後、事前チェックを再実行します。
アラートが事前チェック中に項目に対してトリガーされた場合:
アラート項目を無視できない場合は、失敗した項目の横にある [詳細の表示] をクリックし、問題のトラブルシューティングを行います。その後、事前チェックを再度実行します。
アラート項目を無視できる場合は、[アラートの詳細の確認] をクリックします。[詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されるメッセージで、[OK] をクリックします。次に、[再事前チェック] をクリックして、事前チェックを再度実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
インスタンスを購入します。
[成功率] が 100% になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。
[購入] ページで、データ同期インスタンスの課金方式とインスタンスクラスのパラメーターを構成します。次の表にパラメーターを示します。
セクション
パラメーター
説明
新しいインスタンスクラス
課金方法
サブスクリプション: データ同期インスタンスを作成するときに、サブスクリプションの料金を支払います。 サブスクリプション課金方法は、長期使用の場合、従量課金方法よりも費用対効果が高くなります。
従量課金: 従量課金インスタンスは 1 時間単位で課金されます。従量課金方式は、短期間の使用に適しています。従量課金データ同期インスタンスが不要になった場合は、インスタンスをリリースしてコストを削減できます。
リソースグループ設定
データ同期インスタンスが属するリソースグループ。デフォルト値: [デフォルト リソースグループ]。詳細については、「リソース管理とは」をご参照ください。
インスタンス クラス
DTS では、同期速度が異なるインスタンスクラスを提供しています。ビジネス要件に基づいてインスタンスクラスを選択できます。詳細については、「データ同期インスタンスのインスタンスクラス」をご参照ください。
サブスクリプション期間
サブスクリプション課金方式を選択する場合は、サブスクリプション期間と作成するデータ同期インスタンスの数をご指定ください。サブスクリプション期間は、1~9か月、1年、2年、3年、または5年です。
説明このパラメーターは、サブスクリプション 課金方式を選択した場合にのみ使用できます。
[従量課金制 Data Transmission Service サービス規約] をよく読んで選択してください。
[購入して開始] をクリックします。表示されるダイアログボックスで、OK をクリックします。
タスク リストでタスクの進捗状況を確認できます。
