数据传输服务 DTS：产品架构

DTS系统架构

DTS的系统架构如下图所示。

DTS的系统架构提供以下特性：

• 主备冗余

  DTS的每个功能模块都部署在多个主备冗余服务器上。 容灾系统持续对每台服务器执行健康状况检查。 如果一台服务器运行异常，该服务器上的工作负载将以最小的延迟切换到运行正常的服务器。

• 接入地址动态检测

  对于数据同步和数据订阅，容灾系统会检测数据源接入地址是否发生变更。 如果实例接入地址已更改，则容灾系统将重新配置数据源以保证数据连接正常运行。

数据迁移的工作原理

数据迁移过程包括三个阶段，即结构迁移、全量数据迁移和增量数据迁移。如果需要在迁移期间保持源数据库的正常运行，当您在配置迁移任务时，必须将结构迁移、全量数据迁移和增量数据迁移都选为所需的迁移类型。

在迁移数据之前，DTS需要在目标数据库中重新创建数据结构。对于异构数据库之间的迁移，DTS会解析源数据库的DDL代码，将代码转换成目标数据库的语法，然后在目标数据库中重新创建结构对象。

在全量数据迁移阶段，DTS会将源数据库的存量数据全部迁移到目标数据库。源数据库保持运行状态，在迁移过程中仍不断进行数据更新。 DTS使用增量数据读取模块来获取全量数据迁移过程中发生的数据更新。 当全量数据迁移开始时，增量数据读取模块将被激活。 在全量数据迁移阶段，增量数据会被解析、重新格式化并存储在本地DTS服务器上。

当全量数据迁移完成后，DTS会检索本地存储的增量数据，重新格式化，并将数据更新应用到目标数据库中。 此过程将持续下去，直到所有正在进行的数据变更都复制到目标数据库，并且源数据库和目标数据库完全同步。

数据迁移的流程如下图所示。

数据同步的工作原理

DTS可以在两个数据源之间同步正在进行的数据变更。 数据同步通常用于OLTP到OLAP的数据传输。 数据同步包括以下两个阶段：

• 同步初始化：DTS先开始收集增量数据，然后将源数据库的结构和存量数据加载到目标数据库。
• 数据实时同步：DTS同步正在进行的数据变更，并保持源数据库和目标数据库的同步。

为了同步正在进行的数据变更，DTS使用两个处理事务日志的模块：

• 事务日志读取模块：事务日志读取模块使用相应的协议与源数据库通信，以读取事务日志。 例如，该模块使用Binlog Dump协议从云数据库MySQL中读取事务日志。
• 事务日志应用模块：事务日志应用模块从事务日志读取模块检索并筛选数据更新，仅保留与正在同步的对象相关的数据更新，进而将数据更新应用到目标数据库。 在这个过程中，事务日志应用模块会保持事务的ACID属性，即原子性、一致性、隔离性和持久性。 事务日志读取模块和事务日志应用模块都基于冗余部署。 容灾系统检查每台服务器的健康状况。 如果发生异常，DTS将在运行正常的服务器上恢复执行事务日志。

数据同步的流程如下图所示。

数据订阅的工作原理

DTS的数据订阅模块获取数据更新，并以“发布/订阅流”的形式传输这些数据更新。 您可以为不同的应用定制消费机制。

日志处理模块使用相应的协议与源数据库进行通信，以读取事务日志。 例如，该模块使用Binlog Dump协议从云数据库MySQL中读取事务日志。 然后，日志处理模块解析事务日志，过滤数据，标准格式化更新记录，最终将处理后的数据在本地持久化。

日志处理模块基于冗余部署。 容灾系统检查每台服务器的健康状况。 如果发生异常，DTS将在运行正常的服务器上恢复读取事务日志。

数据订阅的流程如下图所示。