为 Amazon Aurora MySQL 配置多源复制

通过多源复制，您可以将 Amazon Aurora MySQL 数据库集群设置为一个副本，该副本接收来自多个源 MySQL 数据库的二进制日志事件。每个源都可以是 RDS for MySQL 数据库实例、另一个 Aurora MySQL 数据库集群，或在 Amazon RDS 外部运行的 MySQL 数据库。

运行以下引擎版本的 Aurora MySQL 数据库集群支持多源复制：

有关 MySQL 多源复制的更多信息，请参阅 MySQL 文档中的 MySQL Multi-Source Replication。

多源复制的使用案例

在以下情况下，考虑在 Aurora MySQL 上使用多源复制：

多源复制的先决条件

在 Aurora MySQL 数据库集群上配置多源复制之前，请完成为 Aurora MySQL 设置二进制日志复制中所述的二进制日志复制的标准先决条件。这包括在每个源上启用二进制日志记录、保留二进制日志、创建复制用户以及创建每个源的副本或转储。对于多源复制，对每个源数据库实例重复这些步骤。

除标准先决条件外，还需确保满足以下特定于多源复制的要求。

在 Aurora MySQL 数据库集群上配置多源复制通道

在 Aurora MySQL 上配置多源复制通道与配置单源复制类似。对于多源复制，首先要在源实例上启用二进制日志记录，将数据从源导入到 Aurora MySQL 集群，然后使用二进制日志坐标或 GTID 自动定位功能从每个源开始复制。

步骤 1：将数据从源数据库实例导入到 Aurora MySQL 集群

对每个源数据库实例执行以下步骤。

步骤 2：开始从源数据库实例复制到 Aurora MySQL 集群

对于每个源数据库实例，连接到 Aurora MySQL 数据库集群的写入器实例，然后运行存储过程以便在通道上配置和开始复制。

选项 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 自动定位

如果源数据库实例使用基于 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');

对每个源数据库实例重复这些步骤，并为每个源数据库实例指定一个唯一的通道名称（例如 channel_1、channel_2、channel_3）。

将筛选条件与多源复制结合使用

您可以使用复制筛选条件来指定将哪些数据库和表复制到 Aurora MySQL 多源副本。有关复制筛选条件的更多信息，请参阅使用 Aurora MySQL 配置复制筛选条件。下文介绍了多源复制中可用的其它通道级筛选功能。

使用多源复制，您可以在两个级别配置复制筛选条件：

关键行为

监控多源复制通道

您可以使用以下方法监控 Aurora MySQL 多源副本上的各个通道。

使用 SHOW REPLICA STATUS

连接到 Aurora MySQL 数据库集群的写入器实例并运行：

-- 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 数据库集群实例标识符和复制通道名称作为维度。您可以配置 CloudWatch 警报，以便在滞后超过特定的阈值时接收通知。有关更多信息，请参阅 监控 Amazon Aurora 集群中的指标。

管理多源复制存储过程

有关使用存储过程设置和管理多源复制通道的信息，请参阅管理多源复制。

注意事项和最佳实践

有关复制优化的一般建议，包括二进制日志格式、并行工作进程和增强型二进制日志，请参阅优化 Aurora MySQL 的二进制日志复制。以下注意事项特定于多源复制。

资源规划

运行多个复制通道时，副本上分配的复制线程总数为：（replica_parallel_workers + 1 个协调器线程）× 通道数。例如，默认的 replica_parallel_workers 值为 4 且有 10 个通道时，Aurora MySQL 会分配 50 个复制线程。根据您的源总吞吐量和通道计数，考虑使用更大的数据库实例类（例如 db.r6g.2xlarge 或更大）。每个通道接收相同数量的并行工作进程。MySQL 不支持为每个通道设置不同的并行工作进程计数。

避免冲突

MySQL 多源复制不提供冲突检测或解决方案。您必须确保来自不同源的更改不会发生冲突。常见策略包括：

为防止直接连接到多源副本的应用程序发生写入冲突，请在 Aurora MySQL 集群上启用只读模式：CALL mysql.rds_set_read_only(1);

运营最佳实践

限制

以下限制特定于 Aurora MySQL 多源复制。有关 MySQL 多源复制的一般限制（例如每个通道的并行工作线程配置），请参阅 MySQL 文档中的 MySQL Multi-Source Replication。

问题排查

有关一般复制故障排除，请参阅 Amazon Aurora MySQL 复制问题。以下是特定于多源复制的故障排除说明。

快照还原后通道配置未还原

数据库集群快照不包含多源通道配置。从快照还原后：

一个或多个通道上的复制滞后增加

示例：使用三个源完成多源设置

以下示例演示如何将 Aurora MySQL 数据库集群配置为三个 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

对每个通道进行确认：

相关资源