创建数据一致性校验(MySQL 系)

最近更新时间:2024-08-23 16:09:52

我的收藏

操作场景

数据一致性校验,即 DTS 对数据迁移的源库和目标库的表数据进行对比,并给出对比结果和不一致详情,辅助用户在割切前快速验证同步结果。数据一致性校验任务是独立进行的,不会影响源数据库的正常业务,也不会影响 DTS 的任务。
说明:
一致性校验仅作为辅助的数据验证手段。在正式割接前,请用户自行进行演练操作以确保结果满足割接要求。

独立校验和内置校验区别

一致性校验分为独立校验和内置校验两种校验方式,用户可以根据实际诉求选择。
对比项
内置校验
独立校验
定义
校验服务内置于 DTS 任务中,需要在任务运行中时发起一致性校验,DTS 任务停止运行后,不支持发起校验。
校验服务独立于 DTS 任务外,选择源端和目标端相同的数据块进行对比。DTS 任务停止运行后,不支持发起校验。
链路支持
MySQL/MariaDB/Percona/TDSQL-C MySQL/TDSQL TDStore/TDSQL MySQL 迁移、同步链路
MySQL/MariaDB/Percona/TDSQL-C MySQL/TDSQL TDStore 迁移、同步链路
对比范围
仅对比 DTS 任务勾选的同步对象,源库中未勾选的同步对象不在校验范围内。
仅对比由 DTS 写入到目标端的数据,用户自己在目标端写入的数据不在校验范围内。
可对比 DTS 任务中未勾选的其他同步对象。
可对比用户自行在目标端写入的数据。
校验过程中要求
源端可以有 DML 数据写入,不能有 DDL 数据写入,否则校验可能不准确。
建议在静态数据状态下发起校验,即源端和目标端都无数据写入,否则校验结果不准确。

使用场景

当前支持数据一致性校验的链路如下:
MySQL/MariaDB/Percona/TDSQL MySQL > MySQL
MySQL/MariaDB/Percona/TDSQL MySQL > MariaDB
MySQL/MariaDB/Percona > TDSQL-C MySQL
MySQL/MariaDB/Percona/TDSQL MySQL > TDSQL MySQL
MySQL/MariaDB/Percona/TDSQL TDStore > TDSQL TDStore

注意事项及约束

1. 数据一致性校验任务可能会增加源数据库实例的负载,因此请在业务低峰期进行操作。
2. 完整对比、抽样对比需要校验的表必须具有主键或唯一键,否则将跳过不进行校验,行数校验不要求有主键或者唯一键。
3. 当前校验任务对 DDL 操作不感知,如果在迁移过程中,用户对源库做了 DDL 操作,会出现校验结果不一致,需要用户重新发起校验任务才能得到准确的对比结果。
4. 一致性校验任务中,DTS 单次查询源或者目标端数据的超时限制为10min,单次查询指每个分块校验会查询一次,行校验会查询一次等。如果单次查询时间超出10min(例如源端查询的表为大表时),则会导致校验任务失败。
5. 内置校验注意事项。
5.1 内置校验的范围,仅对比源数据库选择的库表对象、和迁移到目标数据库的库表对象。如果用户在迁移任务过程中向目标库进行数据写入,则这部分数据不包含在校验范围内,也不包括其他高级对象(如存储过程、函数、存储过程)、视图、账号等。
5.2 如果在数据一致性校验任务还未结束时,用户选择完成或者终止 DTS 任务,则数据一致性校验任务会失败。
5.3 因为一致性校验需要在源数据库中创建新库 __tencentdb__,并在该库下写入 CheckSum 表,所以源数据库为只读时将会跳过一致性校验。
6. 独立校验约束限制。
如果同步链路中配置了表的重命名,在进行独立校验时,校验对象选择“自定义对象”,然后选择校验对象时需要依次勾表对象,不能勾选整库,否则之前进行过重命名的表,会被跳过校验。

实现原理

DTS 对 MySQL 系数据库的一致性校验是基于 row 模式(binlog_format = row),row 模式可以实现 master 和 slave 的正确复制,保障数据的安全性。
实现原理如下:

1. 在源库创建校验库__tencentdb__.Checksums,用于存储迁移任务过程中的数据对比信息。
2. 选择待校验表的非空唯一键作为校验固定字段。
3. 计算源数据库的校验值 crc1 和行数 count1,并写入到源库的__tencentdb__.Checksums中。
crc 的计算方法类似于分块校验,根据校验固定字段,选取一个固定的范围(例如选取 A 表中,主键从1-1000的数据),将这些数据按行拼接起来计算出一个 crc,这样每个分块数据得到一个 crc,同时计算源库总的数据得到 crc1。
4. DTS 解析 binlog 中的 row 模式数据,还原出在源库写入校验值的 SQL,然后将这个 SQL 在目标库上重放。
目标库上使用与源库相同的变量计算校验值和行数,得到目标库的 crc2 和 count2。
5. 对比源和目标库的校验值和行数,显示对比结果。

创建数据一致性校验任务

自动触发

数据迁移任务设置迁移选项及选择迁移对象页面,数据一致性检查勾选全量检查迁移对象,当后续任务进行到同步增量步骤时自动触发一次一致性校验任务。
自动触发的一致性校验,不能设置校验的详细参数,默认校验对象为“全部迁移对象”,对比类型为“完整对比”,线程数默认采用“1”。


手动创建

1. 登录 DTS 控制台
2. 数据迁移页面,选择需要校验的迁移任务,在操作列单击创建数据一致性校验

3. 单击创建数据一致性校验
说明:
数据一致性校验需要在迁移任务步骤进行到同步增量时,才可以创建。如果界面按钮呈灰色,则 DTS 任务状态不满足条件,如任务未进行到同步增量步骤、任务失败、任务终止。

4. 在弹出的对话框中,单击确定

5. 配置数据一致性校验参数后,单击创建并启动一致性校验

参数
说明
对比类型
内置校验:校验服务内置于 DTS 任务中,仅对比迁移对象数据。
独立校验:校验服务独立于 DTS 任务外,可对比迁移对象外的其他数据。
校验对象
全部迁移对象:校验范围为迁移任务勾选的全部对象。
自定义选择:在勾选的迁移对象中,选择进行校验的对象。
对比类型
完整对比:对所选检验对象的完整数据进行校验。
抽样对比:对所选检验对象抽选一定的比例进行校验,抽样比例支持10%,20%,30%……90%。
行数对比:对所选校验对象,仅对比数据行数。选择行数对比时,不要求表对象有主键,无主键表也可以进行校验。
线程数选择
设置范围为1~8,请根据实际情况选择,提高线程数可加快一致性校验速度,但也会增加源和目标库的负载。

查看数据一致性校验结果

1. 在迁移任务首页,最后一次校验结果列,可查看校验结果,一致或者不一致,单击查看更多进入校验详情页。

2. 单击查看,即可查看校验结果。

3. 查看预估表总数、已检查表数量、不一致表数量、不一致分块数。
预估表总数:预计校验的表总数的估算值,与最终实际校验表总数会有少许差异,因为准确提供预计校验表总数会影响整体校验性能。
未检查表原因:无主键或者非空唯一键、空表、不支持的引擎类型、表不存在。

4. 查看不一致详情。
“内置校验”场景,针对不一致性的结果,需要用户手动对比源数据库和目标数据库的对应内容。
请按照界面提示的数据库数据表索引名称索引上边界索引下边界这些参数定位到具体位置进行对比。
参考操作如下:
1. 登录源数据库,查询提示的索引范围。
select * from table_name where col_index >=1 and col_index <=5;
2. 登录目标数据库,查询提示的索引范围。
3. 对比目标和源的数据差距。
“独立校验”场景,单击对应表后的查看,可查看不一致的数据详情。

查看具体的不一致数据。