Data Transmission Service:MySQL の RDS インスタンスから Tablestore インスタンスへのデータ同期

ソースデータベースの制限事項

自己管理 MySQL の追加要件：

• バイナリロギングを有効化し、binlog_format を row に、binlog_row_image を full に設定します。詳細については、「自己管理 MySQL データベース用のアカウントを作成してバイナリロギングを設定する」をご参照ください。

• デュアルプライマリクラスターでは、DTS がすべてのバイナリログをキャプチャできるよう、log_slave_updates を ON に設定してください。

• タスク実行中にプライマリ/セカンダリ スイッチオーバーを実行すると、タスクが失敗します。

• DTS は、バイナリログファイルの位置を進めるために、予定通りにソースデータベースで CREATE DATABASE IF NOT EXISTS 'test' ステートメントを実行します。

ApsaraDB RDS for MySQL の追加要件：

• トランザクションログを記録しない ApsaraDB RDS for MySQL インスタンス（例：読み取り専用の ApsaraDB RDS for MySQL 5.6 インスタンス）は、ソースデータベースとして使用できません。

• DTS は、バイナリログファイルの位置を進めるために、予定通りにソースデータベースで CREATE DATABASE IF NOT EXISTS 'test' ステートメントを実行します。

ターゲットデータベースの制限事項

一般的な制限事項

ソースおよびターゲットデータベースへのパフォーマンスへの影響を軽減するため、非ピーク時間帯に同期を実行してください。

ステップ 1：データ同期ページへ移動

DTS コンソールまたは DMS コンソールを開き、データ同期ページへ移動します。

ステップ 2：タスクの作成

1. タスクの作成 をクリックして、タスク構成ページを開きます。

2. （任意）プロンプトが表示された場合は、右上隅の 新規構成ページ をクリックします。

   前のバージョンに戻る ボタンが表示されている場合は、このステップをスキップしてください。新旧の構成ページでは、特定のパラメーターが異なる場合があります。新規バージョンの使用を推奨します。

ステップ 3：ソースおよびターゲットデータベースの構成

ソースの ApsaraDB RDS for MySQL インスタンスおよびターゲットの Tablestore インスタンスの接続情報を構成します。

ステップ 4：接続性のテスト

接続性のテストと続行 をクリックします。

DTS は、Alibaba Cloud のデータベースインスタンス（ApsaraDB RDS for MySQL など）のホワイトリストおよび自己管理データベースをホストする Elastic Compute Service (ECS) インスタンスのセキュリティグループルールに、自動的に自サーバーの CIDR ブロックを追加します。オンプレミスデータセンターまたはサードパーティのクラウドプロバイダーでホストされているデータベースの場合は、CIDR ブロックを手動で追加します。詳細については、「DTS サーバーの CIDR ブロック」をご参照ください。

ステップ 5：同期対象の構成

このステップでは、DTS がレプリケーションするテーブル、競合時の処理方法、および Tablestore へのデータ書き込み方法を決定します。

同期オプション：

パラメーター	説明
同期タイプ	スキーマ同期、全量データ同期、および 増分データ同期 を選択します。全量データ同期では、まず既存データをロードし、その後、増分同期によって送信先を継続的な変更と同期させます。
競合テーブルの処理モード	事前チェックを行い、エラーを報告オブジェクト名のマップ（デフォルト）：送信先に同名のテーブルがすでに存在する場合、事前チェックは失敗します。必要に応じて、オブジェクト名マッピング機能を使用して競合するテーブルの名前を変更してください。詳細については、「」をご参照ください。エラーを無視して続行：このチェックをスキップします。全量同期中は、主キーまたは一意キーが一致する既存のレコードはそのまま保持されます。増分同期中は、これらのレコードは上書きされます。ソースと送信先のスキーマが不一致の場合、部分同期やタスクの失敗が発生する可能性があります。慎重に実行してください。
操作タイプ	同期対象の DML 操作です。すべての操作タイプがデフォルトで選択されています。要件に応じて調整してください。
不正データの処理ポリシー	書き込みエラーに対する対応方法：「スキップ」または「ブロック」です。
データ書き込みモード	Tablestore へのデータ書き込み方法です。「行の上書き」では UpdateRowChange 操作を使用し、「行の更新」では PutRowChange 操作を使用します。
バッチ書き込みモード	複数行を一度に書き込む方法です。「BulkImportRequest」（オフライン書き込み）または「BatchWriteRowRequest」（複数行書き込み）から選択します。「BulkImportRequest」は、スループットが高くコストが低いことから推奨されます。
宛先インスタンスにおけるオブジェクト名の大文字小文字設定	Tablestore におけるデータベース名、テーブル名、カラム名の大文字小文字の設定ポリシーです。デフォルト値：「DTS デフォルトポリシー宛先インスタンスにおけるオブジェクト名の大文字小文字の指定」。詳細については、「」をご参照ください。
ソースオブジェクト	同期対象のデータベースまたはテーブルを選択し、 をクリックして「選択済みオブジェクト」に追加します。
選択済みオブジェクト	送信先でのオブジェクト名を変更するには、該当オブジェクトを右クリックします。複数のオブジェクトを一括して名前変更するには、「一括編集オブジェクト名のマップ」をクリックします。詳細については、「」をご参照ください。条件に基づいて行をフィルターするには、テーブルを右クリックし、WHERE 句を指定します。詳細については、「フィルター条件の設定」をご参照ください。

データベース名のマッピングはサポートされていません。オブジェクト名のマッピングは、テーブルを同期対象として選択した場合にのみ適用されます。オブジェクトの名前を変更すると、依存関係のある他のオブジェクトが壊れる可能性があります。カラムタイプの変更は、カラム名マッピング機能を使用して行うことができます。

パフォーマンスチューニング（任意）：

「[詳細]」をクリックして、これらの Tablestore 書き込みパラメーターを設定します。

ステップ 6：高度な設定の構成

[次へ: 詳細設定] をクリックして、以下のオプションを設定します。

ステップ 7：Tablestore のプライマリキー列の構成

[次へ: データベースおよびテーブルフィールドの設定] をクリックし、確認ダイアログで [OK] をクリックします。

DTS は、各ソーステーブルのプライマリキー列をデフォルトで Tablestore にマッピングします。別の列を使用するには、[定義ステータス] を すべて に設定し、[プライマリキー列] のドロップダウンリストから列を選択します。

複合プライマリキーを構成するには、複数のカラムを選択します。

ステップ 8：事前チェックの実行

[次へ: タスク設定を保存して事前チェック] をクリックして構成を保存し、事前チェックを開始します。

このタスク構成の API パラメーターをプレビューするには、[次へ: タスク設定の保存と事前チェック] の上にマウスを移動させ、[OpenAPI パラメーターのプレビュー] をクリックします。

DTS は、タスクを開始する前に事前チェックを実行します。いずれかの項目が失敗した場合：

1. 失敗した項目の横にある[詳細の表示]をクリックして、原因を確認します。

2. 問題を修正してから、[事前チェックを再実行] をクリックします。

項目に対してアラートがトリガーされた場合：

• アラートを無視できる場合は、[アラートの詳細を確認] をクリックし、[無視] をクリックし、[OK] をクリックしてから、[再事前チェック] をクリックします。アラートを無視すると、データの不整合が発生する可能性があります。

• アラートを無視できない場合：問題を解決してから、次のステップに進んでください。

ステップ 9：データ同期インスタンスの購入

成功率が100%に達するまで待ってから、[次: インスタンスの購入]をクリックします。

購入ページで、以下の項目を構成します。

「Data Transmission Service （従量課金）サービス利用規約」を読み、同意してください。その後、[購入して開始] をクリックしてください。

確認ダイアログで [OK] をクリックします。タスクはタスク リストに表示され、進行状況をモニターできます。