Amazon Aurora MySQL のマルチソースレプリケーションを設定する

マルチソースレプリケーションを使用すると、Amazon Aurora MySQL DB クラスターを、複数のソース MySQL データベースからバイナリログイベントを受け取るレプリカとして設定できます。各ソースは、RDS for MySQL DB インスタンス、別の Aurora MySQL DB クラスター、または Amazon RDS の外部で実行されている MySQL データベースとすることができます。

マルチソースレプリケーションは、次のエンジンバージョンを実行している Aurora MySQL DB クラスターでサポートされています。

MySQL マルチソースレプリケーションの詳細については、MySQL ドキュメントの「MySQL マルチソースレプリケーション」を参照してください。

マルチソースレプリケーションのユースケース

以下の場合は、Aurora MySQL でマルチソースレプリケーションを使用することを検討してください。

マルチソースレプリケーションの前提条件

Aurora MySQL DB クラスターでマルチソースレプリケーションを設定する前に、「Aurora MySQL のバイナリログレプリケーションの設定」で説明されているバイナリログレプリケーションのための標準前提条件を満たしてください。これには、各ソースでのバイナリログ記録の有効化、バイナリログの保持、レプリケーションユーザーの作成、各ソースのコピーまたはダンプの作成が含まれます。マルチソースレプリケーションの場合は、ソース DB インスタンスごとにこれらのステップを繰り返します。

標準前提条件に加えて、マルチソースレプリケーションに固有の以下の要件を満たしてください。

Aurora MySQL DB クラスターでマルチソースレプリケーションチャネルを設定する

Aurora MySQL でのマルチソースレプリケーションチャネルの設定は、シングルソースレプリケーションの設定と同様です。マルチソースレプリケーションでは、まずソースインスタンスでバイナリログ記録を有効にし、ソースから Aurora MySQL クラスターにデータをインポートします。次に、バイナリログ座標または GTID 自動配置を使用して各ソースからのレプリケーションを開始します。

ステップ 1: ソース DB インスタンスから Aurora MySQL クラスターにデータをインポートする

各ソース DB インスタンスで以下のステップを実行します。

ステップ 2: ソース DB インスタンスから Aurora MySQL クラスターへのレプリケーションを開始する

ソース DB インスタンスごとに、Aurora MySQL DB クラスターのライターインスタンスに接続し、ストアドプロシージャを実行してチャネルでレプリケーションを設定および開始します。

オプション A: バイナリログファイルの位置の使用

CALL mysql.rds_set_external_source_for_channel(
  'source-endpoint.region.rds.amazonaws.com',
  3306,
  'repl_user',
  'password',
  'mysql-bin-changelog.000031',
  107,
  0,
  'channel_1'
);

CALL mysql.rds_start_replication_for_channel('channel_1');

オプション B: GTID 自動配置の使用

ソース DB インスタンスが GTID ベースのレプリケーションを使用している場合は、バイナリログ座標を指定する代わりに自動配置を使用できます。

CALL mysql.rds_set_external_source_with_auto_position_for_channel(
  'source-endpoint.region.rds.amazonaws.com',
  3306,
  'repl_user',
  'password',
  0,
  0,
  'channel_1'
);

CALL mysql.rds_start_replication_for_channel('channel_1');

ソース DB インスタンスごとにこれらのステップを繰り返し、それぞれに一意のチャネル名を指定します (例: channel_1、channel_2、channel_3)。

マルチソースレプリケーションでフィルターを使用する

レプリケーションフィルターを使用して、Aurora MySQL マルチソースレプリカにレプリケートするデータベースとテーブルを指定できます。レプリケーションフィルターの詳細については、「Aurora MySQL でのレプリケーションフィルターの設定」を参照してください。以下に、マルチソースレプリケーションで使用できる追加のチャネルレベルのフィルター機能について説明します。

マルチソースレプリケーションでは、次の 2 つのレベルでレプリケーションフィルターを設定できます。

主な動作

マルチソースレプリケーションチャネルをモニタリングする

次の方法を使用して、Aurora MySQL マルチソースレプリカの個々のチャネルをモニタリングできます。

SHOW REPLICA STATUS を使用する

Aurora MySQL DB クラスターのライターインスタンスに接続し、以下を実行します。

-- View status for all channels
SHOW REPLICA STATUS\G

-- View status for a specific channel
SHOW REPLICA STATUS FOR CHANNEL 'channel_1'\G

モニタリングする主要フィールド:

CloudWatch メトリクスを使用する

各レプリケーションチャネルの ReplicationChannelLag CloudWatch メトリクスをモニタリングします。このメトリクスは、チャネルごとのレプリケーションの遅延データを 60 秒の期間で提供し、15 日間利用できます。レプリケーションチャネルの遅延を特定するには、Aurora DB クラスターインスタンス識別子とレプリケーションチャネル名をディメンションとして使用します。遅延が特定のしきい値を超えたときに通知を受信するように CloudWatch アラームを設定できます。詳細については、「Amazon Aurora クラスターでのメトリクスのモニタリング」を参照してください。

マルチソースレプリケーションのストアドプロシージャを管理する

ストアドプロシージャを使用してマルチソースレプリケーションチャネルを設定および管理する方法の詳細については、「マルチソースレプリケーションの管理」を参照してください。

考慮事項とベストプラクティス

バイナリログ形式、並列ワーカー、拡張バイナリログなど、レプリケーションの最適化に関する全般的な推奨事項については、「Aurora MySQL でのバイナリログのレプリケーションの最適化」を参照してください。以下の考慮事項は、マルチソースレプリケーションに固有のものです。

リソースの計画

複数のレプリケーションチャネルを実行する場合、レプリカに割り当てられるレプリケーションスレッドの合計数は、(replica_parallel_workers + 1 コーディネータスレッド) × チャネル数になります。例えば、replica_parallel_workers のデフォルト値が 4 で、チャネル数が 10 の場合、Aurora MySQL は 50 個のレプリケーションスレッドを割り当てます。ソースの合計スループットとチャネル数に基づいて、より大きな DB インスタンスクラス (db.r6g.2xlarge 以上など) を使用することを検討してください。各チャネルは、同じ数の並列ワーカーを受け取ります。MySQL は、チャネルごとに異なる並列ワーカー数の設定をサポートしていません。

競合の回避

MySQL マルチソースレプリケーションでは、競合の検出や解決は行われません。異なるソースからの変更が競合していないことを確認する必要があります。一般的な戦略は次のとおりです。

マルチソースレプリカに直接接続するアプリケーションからの書き込みの競合を防ぐには、次のように、Aurora MySQL クラスターで読み取り専用モードを有効にします: CALL mysql.rds_set_read_only(1);

運用のベストプラクティス

制限事項

以下の制限は、Aurora MySQL マルチソースレプリケーションに固有のものです。一般的な MySQL マルチソースレプリケーションの制限 (チャネルあたりの並列ワーカー設定など) については、MySQL ドキュメントの「MySQL マルチソースレプリケーション」を参照してください。

トラブルシューティング

一般的なレプリケーションのトラブルシューティングについては、「 Amazon Aurora MySQL レプリケーションの問題」を参照してください。マルチソースレプリケーション固有のトラブルシューティングメモを次に示します。

スナップショット復元後にチャネル設定が復元されない

DB クラスタースナップショットには、マルチソースチャネル設定は含まれません。スナップショットから復元した後:

1 つ以上のチャネルでレプリケーションの遅延が増える

例: 3 つのソースでマルチソース設定を完了する

次の例は、Aurora MySQL DB クラスターを 3 つの RDS for MySQL ソースインスタンスのマルチソースレプリカとして設定する方法を示しています。

ステップ 1: 各ソースのバイナリログ位置を記録する

各ソースに接続し、バイナリログ座標を記録します。

-- On source 1 (orders-db.xxxxx.us-east-1.rds.amazonaws.com)
SHOW BINARY LOG STATUS;
-- Result: mysql-bin-changelog.000045, Position: 3892

-- On source 2 (inventory-db.xxxxx.us-east-1.rds.amazonaws.com)
SHOW BINARY LOG STATUS;
-- Result: mysql-bin-changelog.000012, Position: 1567

-- On source 3 (analytics-db.xxxxx.us-east-1.rds.amazonaws.com)
SHOW BINARY LOG STATUS;
-- Result: mysql-bin-changelog.000078, Position: 9421

ステップ 2: 各ソースからデータをインポートする

# Import from source 1
mysqldump --databases orders_db --single-transaction --compress \
 -u admin -p --host=orders-db.xxxxx.us-east-1.rds.amazonaws.com | \
 mysql --host=my-aurora-cluster.cluster-xxxxx.us-east-1.rds.amazonaws.com -u admin -p

# Import from source 2
mysqldump --databases inventory_db --single-transaction --compress \
 -u admin -p --host=inventory-db.xxxxx.us-east-1.rds.amazonaws.com | \
 mysql --host=my-aurora-cluster.cluster-xxxxx.us-east-1.rds.amazonaws.com -u admin -p

# Import from source 3
mysqldump --databases analytics_db --single-transaction --compress \
 -u admin -p --host=analytics-db.xxxxx.us-east-1.rds.amazonaws.com | \
 mysql --host=my-aurora-cluster.cluster-xxxxx.us-east-1.rds.amazonaws.com -u admin -p

ステップ 3: レプリケーションチャネルを設定して開始する

Aurora MySQL ライターインスタンスに接続します。

-- Configure channel for source 1 (orders)
CALL mysql.rds_set_external_source_for_channel(
 'orders-db.xxxxx.us-east-1.rds.amazonaws.com',
 3306, 'repl_user', 'password',
 'mysql-bin-changelog.000045', 3892, 0, 'orders_channel'
);

-- Configure channel for source 2 (inventory)
CALL mysql.rds_set_external_source_for_channel(
 'inventory-db.xxxxx.us-east-1.rds.amazonaws.com',
 3306, 'repl_user', 'password',
 'mysql-bin-changelog.000012', 1567, 0, 'inventory_channel'
);

-- Configure channel for source 3 (analytics)
CALL mysql.rds_set_external_source_for_channel(
 'analytics-db.xxxxx.us-east-1.rds.amazonaws.com',
 3306, 'repl_user', 'password',
 'mysql-bin-changelog.000078', 9421, 0, 'analytics_channel'
);

-- Start all channels
CALL mysql.rds_start_replication_for_channel('orders_channel');
CALL mysql.rds_start_replication_for_channel('inventory_channel');
CALL mysql.rds_start_replication_for_channel('analytics_channel');

ステップ 4: レプリケーションステータスを確認する

SHOW REPLICA STATUS\G

チャネルごとに以下を確認します。

関連リソース