Data Transmission Service (DTS) を使用して、PolarDB for PostgreSQL (Oracle 互換) クラスタから AnalyticDB for MySQL 3.0 クラスタにデータを移行できます。
前提条件
宛先 AnalyticDB for MySQL 3.0 クラスタが作成されていること。詳細については、「クラスタの作成」をご参照ください。
ソース PolarDB for PostgreSQL (Oracle 互換) クラスタで、wal_level パラメータが logical に設定されていること。これは、論理エンコーディングに必要な情報が先行書き込みログ (WAL) ログに追加されることを示します。詳細については、「クラスタパラメータの設定」をご参照ください。
考慮事項
種類 | 説明 |
ソースデータベースの制限 |
|
その他 |
|
料金
移行タイプ | リンク構成料金 | データ転送料金 |
スキーマ移行と完全データ移行 | 無料 | インターネット経由で Alibaba Cloud からデータを移行する場合、料金が発生します。詳細については、「課金概要」をご参照ください。 |
増分データ移行 | 料金が発生します。詳細については、「課金概要」をご参照ください。 |
移行タイプ
移行タイプ | 説明 |
スキーマ移行 | DTS は、必要なオブジェクトのスキーマを宛先データベースに移行します。DTS は、テーブルのスキーマ移行をサポートしています。 |
完全データ移行 | DTS は、必要なオブジェクトの既存データをソースデータベースから宛先データベースに移行します。 説明 スキーマ移行と完全データ移行中は、移行対象のオブジェクトに対して DDL 操作を実行しないでください。そうしないと、オブジェクトの移行に失敗する可能性があります。 |
増分データ移行 | 完全データ移行が完了すると、DTS はソースデータベースから REDO ログを取得します。次に、DTS はソースデータベースから宛先データベースに増分データを同期します。 増分データ移行により、PolarDB for PostgreSQL (Oracle 互換) クラスタ間でデータを移行する際にサービスの継続性を確保できます。 |
増分移行できる SQL 操作
操作タイプ | SQL 文 |
DML | INSERT、UPDATE、および DELETE 説明 宛先 AnalyticDB for MySQL V3.0 クラスターにデータが書き込まれると、UPDATE 文は自動的に REPLACE INTO 文に変換されます。プライマリキーに対して UPDATE 文が実行された場合は、UPDATE 文は DELETE 文と INSERT 文に変換されます。 |
データベースアカウントに必要な権限
データベース | 権限 | データベースアカウントを作成して承認する方法 |
PolarDB for PostgreSQL (Oracle 互換) クラスタ | 特権アカウント。 | 詳細については、「データベースアカウントの作成」をご参照ください。 |
AnalyticDB for MySQL 3.0 | 宛先データベースに対する読み取りおよび書き込み権限。 | 詳細については、「データベースアカウントの作成」をご参照ください。 |
手順
次のいずれかの方法を使用して [データ移行] ページに移動し、データ移行インスタンスが存在するリージョンを選択します。
DTS コンソール
DTS コンソール にログインします。
左側のナビゲーションウィンドウで、データの移行 をクリックします。
ページの左上隅で、データ移行インスタンスが存在するリージョンを選択します。
DMS コンソール
説明実際の操作は、DMS コンソールのモードとレイアウトによって異なる場合があります。詳細については、「シンプルモード」および「DMS コンソールのレイアウトとスタイルのカスタマイズ」をご参照ください。
DMS コンソール にログインします。
上部のナビゲーションバーで、ポインタを の上に移動します。
[データ移行タスク] の右側にあるドロップダウンリストから、データ同期インスタンスが存在するリージョンを選択します。
タスクの作成 をクリックして、タスク設定ページに移動します。
ソースデータベースと宛先データベースを構成します。次の表にパラメータを示します。
警告ソースデータベースと宛先データベースを構成した後、ページの上部に表示される [制限] を読んでおくことをお勧めします。そうでない場合、タスクが失敗したり、データの不整合が発生したりする可能性があります。
カテゴリ
パラメータ
説明
該当なし
タスク名
DTS タスクの名前。DTS はタスク名を自動的に生成します。タスクを簡単に識別できる有益な名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
[ソースデータベース]
データベースタイプ
PolarDB (Oracle と互換性) を選択します。
アクセス方法
[クラウドインスタンス] を選択します。
インスタンスリージョン
ソース PolarDB for PostgreSQL (Oracle 互換) クラスタが存在するリージョンを選択します。
[インスタンス ID]
ソース PolarDB for PostgreSQL (Oracle 互換) クラスタの ID を選択します。
[データベース名]
ソース PolarDB for PostgreSQL (Oracle 互換) クラスタのデータベース名を入力します。
データベースアカウント
ソース PolarDB for PostgreSQL (Oracle 互換) クラスタのデータベースアカウントを入力します。アカウントに必要な権限については、「データベースアカウントに必要な権限」をご参照ください。
データベースパスワード
データベースインスタンスへのアクセスに使用するパスワード。
[宛先データベース]
データベースタイプ
[AnalyticDB MySQL 3.0] を選択します。
アクセス方法
[クラウドインスタンス] を選択します。
インスタンスリージョン
宛先 AnalyticDB for MySQL 3.0 データベースが存在するリージョンを選択します。
[インスタンス ID]
宛先 AnalyticDB for MySQL 3.0 クラスタの ID を選択します。
データベースアカウント
宛先 AnalyticDB for MySQL 3.0 データベースのデータベースアカウントを入力します。アカウントに必要な権限については、「データベースアカウントに必要な権限」をご参照ください。
データベースパスワード
データベースインスタンスへのアクセスに使用するパスワード。
ページの下部にある [接続テストと続行] をクリックします。
説明DTS サーバーの CIDR ブロックをソースデータベースと宛先データベースのセキュリティ設定に自動または手動で追加して、DTS サーバーからのアクセスを許可できることを確認してください。詳細については、「DTS サーバーの CIDR ブロックの追加」をご参照ください。
ソースデータベースまたは宛先データベースが自己管理データベースであり、その アクセス方法 が Alibaba Cloud インスタンス に設定されていない場合は、DTS サーバーの CIDR ブロック ダイアログボックスの 接続テスト をクリックします。
移行するオブジェクトを構成します。
オブジェクト設定 ページで、移行するオブジェクトを構成します。
パラメータ
説明
移行タイプ
ビジネス要件に基づいて移行タイプを選択します。移行タイプは、データベースエンジンでサポートされている必要があります。
完全データ移行のみを実行するには、[スキーマ移行] と [完全データ移行] を選択します。
データ移行中のサービスの継続性を確保するには、[スキーマ移行]、[完全データ移行]、および [増分データ移行] を選択します。
説明[スキーマ移行] を選択しない場合は、宛先データベースにデータを受信するためのデータベースとテーブルが作成され、[選択済みオブジェクト] でオブジェクト名マッピング機能が有効になっていることを確認してください。
[増分データ移行] を選択しない場合は、データ移行中にソースデータベースにデータを書き込まないことをお勧めします。これにより、ソースデータベースと宛先データベース間でデータ整合性が確保されます。
競合するテーブルの処理モード
エラーの事前チェックと報告: 宛先データベースにソースデータベースのテーブルと同じ名前を使用するテーブルが含まれているかどうかを確認します。ソースデータベースと宛先データベースに同じテーブル名のテーブルが含まれていない場合、事前チェックは合格です。それ以外の場合、事前チェック中にエラーが返され、データ移行タスクを開始できません。
説明ソースデータベースと宛先データベースに同じ名前のテーブルが含まれており、宛先データベースのテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、宛先データベースに移行されるテーブルの名前を変更できます。詳細については、「データベース、テーブル、および列名マッピング」をご参照ください。
エラーを無視して続行: ソースデータベースと宛先データベースの同じテーブル名の事前チェックをスキップします。
警告エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスが以下の潜在的なリスクにさらされる可能性があります。
ソースデータベースと宛先データベースのスキーマが同じで、データレコードの主キーが宛先データベースの既存のデータレコードと同じである場合、次のシナリオが発生する可能性があります。
完全データ移行中、DTS はデータレコードを宛先データベースに移行しません。宛先データベースの既存のデータレコードは保持されます。
増分データ移行中、DTS はデータレコードを宛先データベースに移行します。宛先データベースの既存のデータレコードは上書きされます。
ソースデータベースと宛先データベースのスキーマが異なる場合、特定の列のみが移行されるか、データ移行タスクが失敗します。注意して進めてください。
同期する DDL および DML 操作
インスタンスレベルで移行する DDL または DML 操作を選択します。サポートされている操作の詳細については、「増分移行できる SQL 操作」をご参照ください。
説明テーブルレベルで増分移行する SQL 操作を選択するには、[選択済みオブジェクト] セクションで移行するオブジェクトを右クリックし、表示されるダイアログボックスで SQL 操作を選択します。
テーブルの結合
[はい]: この値を選択すると、DTS は
__dts_data_source列を各テーブルに追加して、データソースを記録します。詳細については、「複数テーブルマージ機能の有効化」をご参照ください。[いいえ]: これはデフォルト値です。
説明このパラメータを [はい] に設定すると、タスクで選択したすべてのソーステーブルが宛先テーブルにマージされます。特定のソーステーブルをマージする必要がない場合は、これらのテーブルに対して個別のデータ移行タスクを作成できます。
警告ソースデータベースまたはテーブルのスキーマを変更する DDL 操作は実行しないことをお勧めします。そうしないと、データの不整合が発生したり、データ移行タスクが失敗したりする可能性があります。
移行先インスタンスでのオブジェクト名の大文字化
宛先インスタンスのデータベース名、テーブル名、および列名の大文字小文字。デフォルトでは、[DTS デフォルトポリシー] が選択されています。他のオプションを選択して、オブジェクト名の大文字小文字がソースデータベースまたは宛先データベースの大文字小文字と一致するようにすることができます。詳細については、「宛先インスタンスのオブジェクト名の大文字小文字の指定」をご参照ください。
ソースオブジェクト
ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択します。
アイコンをクリックして、選択中のオブジェクト セクションにオブジェクトを追加します。重要増分データ移行 を 移行タイプ に選択した場合、移行対象のオブジェクトとしてテーブルのみを選択できます。一度に選択できるテーブルは 1 つだけです。
増分データ移行移行タイプ で を選択しない場合は、移行対象のオブジェクトとしてデータベース、テーブル、または列を選択できます。
移行対象のオブジェクトとしてデータベースを選択した場合、DTS は次のデフォルトルールに基づいてデータを移行します。
ソースデータベースの移行対象テーブルに主キー (単一列主キーまたは複合主キーなど) がある場合、主キー列が分散キーとして指定されます。
ソースデータベースの移行対象テーブルに主キーがない場合、宛先テーブルに自動採番主キー列が自動的に生成されます。これにより、ソースデータベースと宛先データベース間でデータの不整合が発生する可能性があります。
選択中のオブジェクト
宛先インスタンスに移行するオブジェクトの名前を変更するには、[選択済みオブジェクト] セクションでオブジェクトを右クリックします。詳細については、「個々のデータベース、テーブル、および列名マッピング」をご参照ください。
複数のオブジェクトの名前を一度に変更するには、[選択済みオブジェクト] セクションの右上隅にある [一括編集] をクリックします。詳細については、「データベース、テーブル、および列名の一括マッピング」をご参照ください。
説明オブジェクト名マッピング機能を使用してオブジェクトの名前を変更すると、そのオブジェクトに依存する他のオブジェクトの移行に失敗する可能性があります。
データをフィルタリングするためのフィルタ条件を設定するには、選択中のオブジェクト セクションで移行するテーブルを右クリックし、表示されるダイアログボックスでフィルタ条件を設定します。詳細については、「データをフィルタリングするための SQL 条件の設定」をご参照ください。
データベースまたはテーブルレベルで移行する SQL 操作を選択するには、選択中のオブジェクト セクションで移行するオブジェクトを右クリックし、表示されるダイアログボックスで SQL 操作を選択します。
次へ：詳細設定 をクリックして詳細設定を構成します。
パラメータ
説明
タスクのスケジュールに使用する専用クラスターの選択
デフォルトでは、専用クラスタを指定しない場合、DTS は共有クラスタにデータ移行タスクをスケジュールします。データ移行タスクの安定性を向上させるには、専用クラスタを購入します。詳細については、「DTS 専用クラスタとは」をご参照ください。
失敗した接続の再試行時間
失敗した接続のリトライ時間の範囲。データ移行タスクの開始後にソースデータベースまたはターゲットデータベースへの接続に失敗した場合、DTS はリトライ時間の範囲内で直ちに接続を再試行します。有効値：10 ～ 1,440。単位：分。デフォルト値：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 タスクの作成時にモニタリングとアラートを設定する」セクション（Configure monitoring and alerting に関するトピック）をご参照ください。
[次のステップ: データ検証] をクリックして、データ検証タスクを構成します。
データ検証機能の使用方法の詳細については、「データ検証タスクを構成する」をご参照ください。
オプション: 前述の構成が完了したら、次：データベースおよびテーブルのフィールド設定 をクリックして、ターゲットデータベースで移行するテーブルの タイプ、プライマリキー列の追加、配布キー、およびパーティション情報 (パーティションキー、パーティションルール、パーティションのライフサイクル) を構成します。
説明このステップは、タスクオブジェクトを構成するときに、移行タイプ で スキーマ移行 を選択した場合にのみ使用できます。 定義ステータス で すべて を選択し、設定を変更できます。
複数の列を選択して複合 プライマリキー列の追加 を形成できます。 プライマリキー列の追加 から 1 つ以上の列を 配布キー および パーティションキー として選択する必要があります。 詳細については、「CREATE TABLE」をご参照ください。
タスク設定を保存し、事前チェックを実行します。
DTS タスクを設定するために関連 API 操作を呼び出すときに指定するパラメーターを表示するには、 次：タスク設定の保存と事前チェック にポインターを移動し、 OpenAPI パラメーターのプレビュー をクリックします。
パラメーターを表示する必要がない場合、またはすでに表示済みの場合は、ページの下部にある 次：タスク設定の保存と事前チェック をクリックします。
説明データ移行タスクを開始する前に、DTS は事前チェックを実行します。タスクが事前チェックに合格した後にのみ、データ移行タスクを開始できます。
タスクが事前チェックに合格しなかった場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題をトラブルシューティングします。その後、再度事前チェックを実行します。
事前チェック中に項目に対してアラートがトリガーされた場合:
アラート項目を無視できない場合は、失敗した項目の横にある [詳細の表示] をクリックし、問題をトラブルシューティングします。その後、再度事前チェックを実行します。
アラート項目を無視できる場合は、 [アラート詳細の確認] をクリックします。 [詳細の表示] ダイアログボックスで、 [無視] をクリックします。表示されるメッセージで、 [OK] をクリックします。次に、 [再チェック] をクリックして、再度事前チェックを実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
インスタンスを購入します。
[成功率] が [100%] になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。
[インスタンスの購入] ページで、データ移行インスタンスのインスタンスクラスパラメーターを設定します。次の表にパラメーターを示します。
セクション
パラメーター
説明
新しいインスタンスクラス
リソースグループ
データ移行インスタンスが属するリソースグループ。デフォルト値: [デフォルトのリソースグループ]。詳細については、「リソース管理とは」をご参照ください。
インスタンスクラス
DTS では、移行速度が異なるインスタンスクラスを提供しています。ビジネスシナリオに基づいてインスタンスクラスを選択できます。詳細については、「データ移行インスタンスのインスタンスクラス」をご参照ください。
チェックボックスをオンにして、[Data Transmission Service (従量課金制) サービス規約] を読んで同意します。
[購入して開始] をクリックします。表示されるメッセージで、[OK] をクリックします。
[データ移行] ページでタスクの進捗状況を確認できます。
説明データ移行タスクを使用して増分データを移行できない場合、タスクは自動的に停止します。[完了] が [ステータス] セクションに表示されます。
データ移行タスクを使用して増分データを移行できる場合、タスクは自動的に停止しません。増分データ移行タスクは停止または完了しません。[実行中] が [ステータス] セクションに表示されます。