Percona Toolkit 神器全攻略(复制类)

Percona Toolkit 神器全攻略(复制类)

Percona Toolkit 神器全攻略系列共八篇,前文回顾:

前文回顾
Percona Toolkit 神器全攻略
Percona Toolkit 神器全攻略(实用类)
Percona Toolkit 神器全攻略(配置类)
Percona Toolkit 神器全攻略(监控类)
Percona Toolkit 神器全攻略(系统类)
Percona Toolkit 神器全攻略(开发类)

全文约定:$为命令提示符、greatsql>为GreatSQL数据库提示符。在后续阅读中,依据此约定进行理解与操作

复制类

在Percona Toolkit中复制类共有以下工具

  • pt-heartbeat:监控MySQL/GreatSQL复制延迟
  • pt-slave-delay:设定从落后主的时间
  • pt-slave-find:查找和打印所有MySQL/GreatSQL复制层级关系
  • pt-slave-restart:监控Salve错误,并尝试重启Salve
  • pt-table-checksum:校验主从复制一致性
  • pt-table-sync:高效同步表数据
  • pt-galera-log-explainer:对多个 Galera 日志进行过滤、聚合和汇总

pt-heartbeat

概要

用来监测主从延迟的情况,此工具的设计为向 Master 中插入一条带有当前时间(GreatSQL中的now()函数)的记录到心跳表中,然后,该记录会复制到 Slave 中。Slave 根据当前的系统时间戳(Perl中的time函数)减去heartbeat表中的记录值来判断主从的延迟情况。

用法

  • pt-heartbeat [OPTIONS] [DSN] --update|--monitor|--check|--stop

选项

至少指定 --stop--update--monitor--check 之一

互斥关系

--update--monitor--check 是互斥的

--daemonize--check 是互斥的

该工具所有选项如下

参数 含义
--ask-pass 连接MySQL/GreatSQL提示输入密码
--charset 默认字符集
--check 检查一次从机延迟并退出
--check-read-only 检查服务器是否启用了read_only
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--create-table 如果heartbeat表--table不存在,则创建它
--create-table-engine 设置用于heartbeat表的引擎
--daemonize 后台运行
--database 用于连接的数据库
--dbi-driver 指定连接的驱动程序
--defaults-file 只从给定文件中读取 GreatSQL 选项
--file 将最新的--monitor输出打印到此文件
--frames 平均值的时间范围,默认为1m,5m,15m
--help 显示帮助
--host 连接到主机
--[no]insert-heartbeat-row 如果--table中不存在心跳行,则插入该行
--interval 更新或检查heartbeat表的频率,默认1秒
--log 后台运行时将所有输出打印到此文件
--master-server-id 根据此主服务器 ID 计算--monitor--check的延迟
--monitor 连续监控从机延迟
--fail-successive-errors 如果指定,将在给定数量的连续 DBI 错误(无法连接到服务器或发出查询)后失败
--password 连接时使用的密码
--pid 创建给定的 PID 文件
--port 用于连接的端口号
--print-master-server-id 打印自动检测到的或给定的--master-server-id
--read-only-interval 当指定--check-read-only 时,发现服务器处于只读状态时休眠的时间间隔
--recurse --check模式下递归检查从站到此深度
--recursion-method 用于查找从站的首选递归方法
--replace 使用REPLACE而不是UPDATE进行 –update
--run-time 运行时间
--sentinel 如果该文件存在则退出
--slave-user 设置用于连接从站的用户
--slave-password 设置用于连接从站的密码
--set-vars 在这个以逗号分隔的variable=value对列表中设置 MySQL/GreatSQL 变量
--skew 延迟检查多久,默认值:0.5
--socket 用于连接的套接字文件
--stop 通过创建哨兵文件来停止运行实例
--table 用于心跳的表
--update 更新主机的心跳
--user 登录的用户
--utc 忽略系统时区并仅使用 UTC
--version 显示版本
--[no]version-check 版本检查

最佳实践

为演示该工具,在主机上部署单机多实例并搭建一主一从模式,环境如下:

数据库 IP 端口号 角色
GreatSQL-8.0.32-25 192.168.6.55 3306 Master
GreatSQL-8.0.32-25 192.168.6.55 3307 Slave

首先需要在Master上添加表

$ pt-heartbeat --user=root --ask-pass -S /data/GreatSQL/mysql.sock -D test_db --master-server-id=103306 --create-table --update

-D:选择一个数据库中有的库

--master-server-id:设置主机的server_id

--create-table:用于创建表

--update:会每秒更新一次heartbeat表的记录

现在进入Master上可以看到在test_db库下有一张heartbeat表,这里有一条记录的数据。在Slave节点上也应该出现这张表

greatsql> SELECT * FROM test_db.heartbeat;
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+
| ts                         | server_id | file          | position | relay_master_log_file | exec_master_log_pos |
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+
| 2024-04-22T15:57:44.001900 |    103306 | binlog.000032 |    41464 | NULL                  |                NULL |
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+
1 row in set (0.00 sec)

接下来我们更新主库上这张表,并让他在后台运行

$ pt-heartbeat --user=root --ask-pass -S /data/GreatSQL/mysql.sock -D test_db --master-server-id=103306 --update --daemonize

进入从机,开始监控主从延迟

$ pt-heartbeat --user=root --ask-pass -S /data/GreatSQL02/mysql.sock -D test_db --master-server-id=103306 --monitor --print-master-server-id
Enter password:
0.00s [  0.00s,  0.00s,  0.00s ] 103306
0.00s [  0.00s,  0.00s,  0.00s ] 103306
0.00s [  0.00s,  0.00s,  0.00s ] 103306
0.00s [  0.00s,  0.00s,  0.00s ] 103306

输出的结果为:实时延迟,[1分钟延迟,5分钟延迟,15分钟延迟] 主节点的Server_id

  1. 当然也可以使用--interval参数控制主库上的更新间隔,默认是1秒

  2. 如果使用守护进程的方式,要关闭的话可以采用pt-heartbeat --stop

  3. 单次查看Slave库上的延迟情况可以把monitor换成--check

pt-slave-delay

概要

可能在日常工作中会存在误删除数据的可能,所以可以用该工具设置Slave服务器落后于Master服务器,达到构建一个延迟从库

原理

通过启动和停止复制SQL线程来设置Slave库落后于Master库的指定时间

用法

  • pt-slave-delay [OPTIONS] SLAVE_DSN [MASTER_DSN]

选项

该工具所有选项如下

参数 含义
--ask-pass 连接时提示输入密码
--charset 默认字符集
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--[no]continue 退出后继续正常复制
--daemonize 后台运行
--database 用于连接的数据库
--defaults-file 只从给定文件中读取MySQL/GreatSQL选项
--delay 从库延迟于主库的时间,默认1小时
--help 显示帮助
--host 连接到主机的IP地址
--interval 启动或停止的频率。默认1分钟
--log 后台运行时日志输出的位置
--password 连接时使用的密码
--pid 创建给定的 PID 文件
--port 用于连接的端口号
--quiet 不要打印有关操作的信息性消息
--run-time 运行时间,默认是一直运行
--set-vars 在这个以逗号分隔的variable=value对列表中设置 MySQL/GreatSQL 变量
--socket 用于连接的套接字文件
--use-master 从Master库获取二进制日志位置,而不从Slave库获取
--user 用于登录的用户
--version 显示版本
--[no]version-check 版本检查

最佳实践

此工具只需在Slave库运行即可,无需在Master节点运行

$ pt-slave-delay --user=root --ask-pass -S /data/GreatSQL02/mysql.sock --delay=1m --interval=15s --run-time=10m

将主从延迟设定为1分钟,每15秒进行一次检测,持续运行10分钟

输出结果如下

2024-04-23T09:29:00 slave running 0 seconds behind
2024-04-23T09:29:00 STOP SLAVE until 2024-04-23T09:30:00 at master position binlog.000032/500611
2024-04-23T09:29:15 slave stopped at master position binlog.000032/500611
2024-04-23T09:29:30 slave stopped at master position binlog.000032/500611
......中间省略
2024-04-23T09:30:30 Setting slave to run normally

如果在运行的过程中进入Slave节点查看SHOW SLAVE STATUS\G

Slave_IO_Running: Yes
Slave_SQL_Running: No

可以看到SQL线程已关闭,证明此工具精准控制SQL线程的启停,有效实现主从延迟

也可使用CHANGE REPLICATION SOURCE TO SOURCE_DELAY=3600;该命令来控制主从延迟的时间

pt-slave-find

概要

查找和打印主从架构中主库的从库个数,类似于拓扑图的意思

用法

  • pt-slave-find [OPTIONS] [DSN]

选项

参数 含义
--ask-pass 连接MySQL/GreatSQL提示输入密码
--charset 默认字符集
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--databases 仅检查此逗号分隔的数据库列表
--defaults-file 只从给定文件中读取 MySQL/GreatSQL 选项
--help 显示帮助
--host 连接到主机
--password 连接时使用的密码
--pid 创建给定的 PID 文件
--port 用于连接的端口号
--recurse 层次结构中要递归的级别数,默认为无限
--recursion-method 用于查找从库的首选递归方法,有三种 (processlist、hosts、none)
--report-format 设置打印有关从库的哪些信息
--resolve-address 将 IP 地址解析为主机名
--slave-user 设置用于连接从库的用户
--slave-password 设置用于连接从库的密码
--set-vars 以逗号分隔的variable=value对列表中设置 MySQL/GreatSQL 变量
--socket 用于连接的套接字文件
--user 登录的用户
--version 显示版本

最佳实践

连接到主从集群的Master节点,查看该集群的复制层次数

$ pt-slave-find h=192.168.6.55,u=root --ask-pass
192.168.6.55
Version         8.0.32-25
Server ID       103306
Uptime          20:38:01 (started 2024-04-22T14:09:23)
Replication     Is not a slave, has 1 slaves connected, is not read_only
Filters
Binary logging  ROW
Slave status
Slave mode      STRICT
Auto-increment  increment 1, offset 1
InnoDB version  8.0.32-8.0.32
+- 192.168.6.55:3307
   Version         8.0.32-25
   Server ID       103307
   Uptime          20:35:59 (started 2024-04-22T14:12:02)
   Replication     Is a slave, has 0 slaves connected, is not read_only
   Filters
   Binary logging  ROW
   Slave status    0 seconds behind, running, no errors
   Slave mode      STRICT
   Auto-increment  increment 1, o
   InnoDB version  8.0.32-8.0.32

可以看到该主节点下只有一个从节点,且输出也显示了主节点和总结点的信息

pt-slave-restart

概要

监视一个或多个 GreatSQL 复制从库是否有错误,并在复制停止时尝试重新启动复制

用法

  • pt-slave-restart [OPTIONS] [DSN]

选项

参数 含义
--always 永不停止Slave线程
--ask-pass 连接MySQL/GreatSQL提示输入密码
--charset 默认字符集
--[no]check-relay-log 在检查从库错误之前检查最后一个中继日志文件和位置
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--daemonize 后台运行
--databases 数据库列表
--defaults-file 只从给定文件中读取 MySQL/GreatSQL 选项
--error-length 要打印的错误消息的最大长度
--error-numbers 指定跳过哪些错误,可用,进行分隔
--error-text 根据错误的信息进行匹配跳过
--help 显示帮助
--host 连接到主机
--log 后台运行时,将输出打印到此文件
--max-sleep 再次轮询从库之前休眠的最长时间
--min-sleep 再次轮询从库之前休眠眠的最短时间
--monitor 是否监控从机(默认)
--password 连接时使用的密码
--pid 创建给定的 PID 文件
--port 用于连接的端口号
--quiet 抑制正常输出(禁用--verbose
--recurse 在主库执行,监控从库,默认深度 0 表示“仅监视指定的从库”
--recursion-method 用于查找从库的首选递归方法
--run-time 运行时间
--sentinel 如果该文件存在则退出,默认值:/tmp/pt-slave-restart-sentinel
--slave-user 设置用于连接从库的用户
--slave-password 设置用于连接从库的密码
--set-vars 以逗号分隔的variable=value 对列表中设置 MySQL/GreatSQL 变量
--skip-count 重新启动从库时要跳过的语句数,默认1
--master-uuid 使用 GTID 时,应创建一个空事务以便跳过它
--sleep 检查从库之间的初始睡眠秒数
--socket 用于连接的套接字文件
--stop 停止运行实例
--until-master 运行到指定的master_log_pos,file位置后停止
--until-relay 运行到指定的中继日志文件和位置后停止
--user 用于登录的用户
--verbose 向输出添加更多信息
--version 显示版本
--[no]version-check 版本检查

最佳实践

在主库创建一张t1表,并插入5条数据

greatsql> CREATE TABLE t1 (id INT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(255) NOT NULL);
greatsql> INSERT INTO t1 (name) VALUES ('张三');  
greatsql> INSERT INTO t1 (name) VALUES ('李四');  
greatsql> INSERT INTO t1 (name) VALUES ('王五');  
greatsql> INSERT INTO t1 (name) VALUES ('赵六');  
greatsql> INSERT INTO t1 (name) VALUES ('孙七');

主库查看数据

greatsql> SELECT * FROM test_db.t1;
+----+--------+
| id | name   |
+----+--------+
|  1 | 张三   |
|  2 | 李四   |
|  3 | 王五   |
|  4 | 赵六   |
|  5 | 孙七   |
+----+--------+
5 rows in set (0.00 sec)

从库查看数据

greatsql> SELECT * FROM test_db.t1;
+----+--------+
| id | name   |
+----+--------+
|  1 | 张三   |
|  2 | 李四   |
|  3 | 王五   |
|  4 | 赵六   |
|  5 | 孙七   |
+----+--------+
5 rows in set (0.00 sec)

主动处理错误

在从库执行pt-slave-restart工具监控从库

$ pt-slave-restart h=192.168.6.55,P=3307,u=root --ask-pass

注意,若使用该工具,参数slave_parallel_workers必须设置为0,否则会报错”Cannot skip transactions properly because GTID is enabled and slave_parallel_workers > 0. See 'GLOBAL TRANSACTION IDS' in the tool's documentation.“ 如果不关闭多线程复制,工具会分不清到底哪个线程复制出了问题

此时已经开启了从库监控,我们在主库上人为造成一个主从复制错误

greatsql> SET sql_log_bin=0;
greatsql> INSERT INTO t1 VALUES(6,'周八');
greatsql> SET sql_log_bin=1;
greatsql> DELETE FROM t1 WHERE id=6;

此时工具检测到了主从复制异常,并且马上修复了该错误,使主从复制正常运行

$ pt-slave-restart h=192.168.6.55,P=3307,u=root --ask-pass
# 时间戳 + 从库端信息 + relay log + relat log 位置 + 主从复制报错码
2024-04-24T10:33:54 P=3307,h=192.168.6.55,u=root myarch-relay-bin.000003   36702 1032

手动处理错误

如果一直运行工具,检测到错误会直接修复。如果是已经有错误了要如何使用该工具修复?还是同样的错误,再次主库手动执行

greatsql> SET sql_log_bin=0;
greatsql> INSERT INTO t1 VALUES(6,'周八');
greatsql> SET sql_log_bin=1;
greatsql> DELETE FROM t1 WHERE id=6;

此时查看从库报错

greatsql> SHOW SLAVE STATUS\G
Slave_IO_Running: Yes
Slave_SQL_Running: No
Last_SQL_Error: Could not execute Delete_rows event on table test_db.t1; Can't find record in 't1', Error_code: 1032; handler error HA_ERR_KEY_NOT_FOUND; the event's master log binlog.000032, end_log_pos 504208

记住报错的错误码1032,接着在从库机器上使用该工具

$ pt-slave-restart h=192.168.6.55,P=3307,u=root --ask-pass --error-numbers=1032

使用--error-numbers=指定错误码

此时就会输出对应的信息

$ pt-slave-restart h=192.168.6.55,P=3307,u=root --ask-pass --error-numbers=1032

2024-04-24T10:49:26 P=3307,h=192.168.6.55,u=root myarch-relay-bin.000003     37046 1032

接着在从库上查看主从状态,就可以看到主从复制已经是正常的了

greatsql> SHOW SLAVE STATUS\G
Slave_IO_Running: Yes
Slave_SQL_Running: Yes
Last_SQL_Error:

pt-table-checksum

这款数据校验与修复工具虽广受欢迎,却存在不容忽视的短板:不支持MySQL/GreatSQL的MGR场景、国内普遍的上云下云业务,以及MySQL/GreatSQL与Oracle间的异构数据库等多元化场景。为了攻克这些难题,GreatSQL推出了名为gt-checksum的校验&修复工具,旨在全面满足各类业务需求!

概要

检查 MySQL/GreatSQL 的主从数据是否一致

用法

  • pt-table-checksum [OPTIONS] [DSN]

选项

参数 含义
--ask-pass 连接MySQL/GreatSQL提示输入密码
--channel 指定复制通道
--[no]check-binlog-format 检查所有服务器上的binlog_format系统参数是否相同
--binary-index 修改--create-replicate-table的行为,使复制表的上下边界列以 BLOB 数据类型创建
--check-interval 指定因选项--max-lag检查之间休眠时间
--[no]check-plan 检查查询执行计划的安全性
--[no]check-replication-filters 指定检测主从复制是否有设置复制过滤器
--check-slave-lag 指定复制延迟大于选项--max-lag指定的值之后暂停检查校验操作
--[no]check-slave-tables 检查从库上的表是否存在并具有所有校验和--columns
--chunk-index 指定使用哪个索引对表进行chunk分块操作
--chunk-index-columns 指定使用选项--chunk-index的索引使用最左前缀几个索引字段,只适用于复合索引
--chunk-size 为每个校验和查询选择的行数,允许的后缀单位为k、M、G
--chunk-size-limit 指定chunk的行数最多可以超过选项--chunk-size指定的行数的多少倍
--chunk-time 动态调整每个chunk的大小使相应的表行数都在指定的时间内完成校验操作
--columns 指定只需要校验的字段,如有多个则用逗号隔开
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--[no]create-replicate-table 创建选项--replicate指定的数据库和表
--databases 仅对逗号分隔的数据库列表进行校验
--databases-regex 仅名称与此正则表达式匹配和数据库进行校验
--defaults-file 只从给定文件中读取 MySQL/GreatSQL 选项
--disable-qrt-plugin 如果启用了 QRT(查询响应时间)插件,请将其禁用
--[no]empty-replicate-table 在对表进行校验和之前,删除每个表之前的校验和
--engines 仅校验使用这些存储引擎的表
--explain 显示但不执行校验和查询(禁用--[no]empty-replicate-table
--fail-on-stopped-replication 若复制停止,则会失败并显示错误(退出状态 128),而不是等到复制重新启动
--float-precision FLOAT 和 DOUBLE 数字到字符串转换的精度
--function 指定校验操作使用的哈希函数。可选函数有SHA1、MD5等
--help 显示帮助
--host 连接到主机
--ignore-columns 指定需要忽略校验的字段
--ignore-databases 指定需要忽略校验的数据库
--ignore-databases-regex 指定采用正则表达式匹配忽略校验的数据库
--ignore-engines 指定需要忽略校验的存储引擎列表
--ignore-tables 指定需要忽略校验的表
--ignore-tables-regex 指定采用正则表达式匹配忽略校验的表
--max-lag 指定允许主从复制延迟时长的最大值,单位秒
--max-load 在每个块之后检查`SHOW GLOBAL STATUS,如果任何状态变量高于阈值则暂停
--password 连接时使用的密码
--pause-file 当此参数指定的文件存在时,执行将暂停
--pid 创建给定的 PID 文件
--plugin 定义pt_table_checksum_plugin类的 Perl 模块文件
--port 用于连接的端口号
--progress 将进度报告打印到 STDERR
--quiet 仅打印最重要的信息(禁用 --progress
--recurse 指定搜寻从库的层级,默认无限
--recursion-method 指定获取从库的方式
--replicate 将校验和结果写入此表
--[no]replicate-check 指定在校验完每张表后检查主从当前表是否出现不一致
--replicate-check-only 检查副本的一致性,而无需执行校验和查询
--replicate-check-retries 指定当校验出主从数据不一致重试校验的次数
--replicate-database 指定工具在执行校验操作时在哪个数据库下进行
--resume 指定从最后完成校验的chunk开始恢复校验
--retries 指定当出现非严重性错误时重复校验一个块的次数
--run-time 指定校验操作运行的时间
--separator 用于 CONCAT_WS() 的分隔符
--skip-check-slave-lag 指定DSN连接从库时跳过主从延迟检查,可以指定多个从库检查
--slave-user 设置用于连接从库的用户
--slave-password 设置用于连接从库的密码
--set-vars 运行检查时指定参数值,如有多个用逗号分隔
--socket 用于连接的套接字文件
--slave-skip-tolerance 当主表被标记为仅在一个块中进行校验和,但从表超过了可接受的最大大小时,该表将被跳过
--tables 仅对这个以逗号分隔的表列表进行校验和
--tables-regex 仅对名称与此 Perl 正则表达式匹配的表进行校验
--trim 将 TRIM() 添加到 VARCHAR 列(在比较 4.1 和 >= 5.0 时有帮助)
--truncate-replicate-table 在开始校验和之前截断复制表
--user 登录的用户
--version 显示版本
--[no]version-check 版本检查
--where 仅执行与此 WHERE 子句匹配的行

最佳实践

校验主从数据是否一致(主从端口一致)

主从机器端口一致时,可以使用此方法

检测差异,并写入差异到checksums表中,主库上执行如下命令

pt-table-checksum --create-replicate-table --replicate=test_db.checksums --nocheck-replication-filters --nocheck-binlog-format --recursion-method=processlist --databases=test_db --user=root --ask-pass --host=192.168.6.55 --port=3306
  • --nocheck-replication-filters:不检查复制过滤器,建议启用

  • --no-check-binlog-format:不检查复制的binlog模式,要是binlog模式是ROW,则会报错

结果如下

Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
04-24T15:57:13      0      0        9          0       1       0   0.008 test_db.test_t1
  • TS:完成检查的时间
  • ERRORS:检查时候发生错误和警告的数量
  • DIFFS:0表示一致,非0表示不一致
  • DIFF_ROWS:主库和从库差异的数据行数
  • CHUNKS:被划分到表中的块的数目
  • SKIPPED:由于错误或警告或过大,则跳过块的数目
  • TIME:执行的时间
  • TABLE:被检查的表名

同时结果也保存到了表中

greatsql> select * from checksums;
+---------+--------------------+-------+------------+-------------+----------------+----------------+----------+----------+------------+------------+---------------------+
| db      | tbl                | chunk | chunk_time | chunk_index | lower_boundary | upper_boundary | this_crc | this_cnt | master_crc | master_cnt | ts                  |
+---------+--------------------+-------+------------+-------------+----------------+----------------+----------+----------+------------+------------+---------------------+
| test_db | t1                 |     1 |   0.001848 | NULL        | NULL           | NULL           | 6d60e23f |        5 | 6d60e23f   |          5 | 2024-04-24 16:29:30 |
+---------+--------------------+-------+------------+-------------+----------------+----------------+----------+----------+------------+------------+---------------------+
1 rows in set (0.01 sec)

校验主从数据是否一致(主从端口不一致)

主从机器端口不一致时,可以使用此方法

在主库创建一张DSN表

greatsql> CREATE TABLE test_db.dsns ( id int(11) NOT NULL AUTO_INCREMENT, parent_id int(11) DEFAULT NULL,dsn varchar(255) NOT NULL, PRIMARY KEY (id) );

greatsql> INSERT INTO test_db.dsns(dsn) VALUES ('h=192.168.6.55,P=3307,u=root,p=');

使用工具校验,注意此时--recursion-method就要改为DSN模式

$ pt-table-checksum --replicate=test_db.checksums --nocheck-replication-filters --no-check-binlog-format --host=192.168.6.55 --port=3306 --user=root --ask-pass --databases=test_db --recursion-method dsn=h=192.168.6.55,D=test_db,t=dsns

结果如下

Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
04-24T17:04:42      0      0        1          0       1       0   0.035 test_db.dsns
04-24T17:04:42      0      0        1          0       1       0   0.022 test_db.heartbeat
04-24T17:04:42      0      0        0          0       1       0   0.036 test_db.my_table
04-24T17:04:42      0      2    10000       9823       4       0   0.097 test_db.ptosc
04-24T17:04:42      0      0        5          0       1       0   0.021 test_db.t1
04-24T17:04:42      0      1       15         15       1       0   0.026 test_db.tc10011_ta4
04-24T17:04:42      0      1        9          9       1       0   0.078 test_db.test_t1
04-24T17:04:42      0      0        0          0       1       0   0.066 test_db.test_table

可以看到有三张表被检测出来不一致。如果连表都不存在则会报错Table 'XXXX' doesn't exist

出现了主从数据不一致,就要使用pt-table-sync工具进行修复

pt-table-sync

概要

高效同步 MySQL/GreatSQL 表数据

用法

  • pt-table-sync [OPTIONS] DSN [DSN]

选项

至少指定 --print--execute--dry-run 之一。--where--replicate 是互斥的

参数 含义
--algorithms 比较表时使用的算法(按优先顺序),默认值:Chunk、Nibble、GroupBy、Stream
--ask-pass 连接 MySQL/GreatSQL 提示输入密码
--bidirectional 启用第一个和后续主机之间的双向同步
--[no]bin-log 指定同步操作记录二进制日志,相当于执行SET SQL_LOG_BIN=1
--buffer-in-mysql 指定 MySQL/GreatSQL 在其内存中缓冲查询
--[no]buffer-to-client 比较时从 MySQL/GreatSQL 中逐一获取行
--channel 指定复制通道
--charset 默认字符集
--[no]check-child-tables 检查--execute是否会对子表产生不利影响
--[no]check-master 指定当选项--sync-to-master时,尝试验证工具连接到的主库是否是真正的主库
--[no]check-slave 检查目标服务器是否为从服务器
--[no]check-triggers 检查目标表上是否未定义触发器
--chunk-column 指定根据表中字段对表进行chunk操作
--chunk-index 指定使用哪个索引对表进行chunk分块操作
--chunk-size 每个块的行数或数据大小
--columns 比较以逗号分隔的列列表
--config 读取这个逗号分隔的配置文件列表,如果指定,这必须是命令行上的第一个选项
--conflict-column --bidirectional同步期间发生行冲突时比较此列
--conflict-comparison 选择具有此属性的--conflict-column作为源
--conflict-error 如何报告无法解决的冲突和冲突错误,默认为:warn(警告)
--conflict-threshold 一个--conflict-column必须超过另一个的数量
--conflict-value 将此值用于某些--conflict-comparison
--databases 仅同步的数据库列表,如有多个用逗号分隔
--defaults-file 只从给定文件中读取 GreatSQL 选项
--dry-run 分析、决定要使用的同步算法、打印并退出
--engines 仅同步的存储引擎列,如有多个用逗号分隔
--execute 执行查询以使表具有相同的数据
--explain-hosts 打印连接信息并退出
--float-precision FLOATDOUBLE 数字到字符串转换的精度
--[no]foreign-key-checks 启用外键检查 (SET FOREIGN_KEY_CHECKS=1)
--function 选择使用哪个哈希函数作为校验和,默认为 CRC32
--help 显示帮助
--[no]hex-blob HEX() BLOB、TEXT和 BINARY列
--host 连接到主机
--ignore-columns 要忽略的列,如有多个用逗号分隔
--ignore-databases 要忽略的数据库,如有多个用逗号分隔
--ignore-engines 要忽略的引擎,如有多个用逗号分隔
--ignore-tables 要忽略的表,如有多个用逗号分隔
--ignore-tables-regex 要忽略的表正则表达式,如有多个用逗号分隔
--[no]index-hint 将 FORCE/USE INDEX 提示添加到块和行查询中
--lock 锁定表:0=永不锁表,1=每个同步周期锁表,2=表操作时锁表,3=每个DSN连接的服务器锁表
--lock-and-rename 指定锁定源表和目标表,执行同步操作,然后进行表名交换
--password 连接时使用的密码
--pid 创建给定的 PID 文件
--port 用于连接的端口号
--print 打印将解决差异的查询
--recursion-method 用于查找从站的首选递归方法
--replace 将所有INSERTUPDATE语句写为REPLACE
--replicate 同步此表中列为不同的表
--slave-user 设置用于连接从库的用户
--slave-password 设置用于连接从库的密码
--set-vars 以逗号分隔的variable=value对列表中设置 MySQL/GreatSQL 变量
--socket 用于连接的套接字文件
--sync-to-master 指定将DSN连接信息确认为从库,并同步信息到主库
--tables 要同步的表,如有多个用逗号分隔
--timeout-ok 指定当选项--wait导致工具执行失败时跳过失败继续执行
--[no]transaction 指定工具操作使用事务代替LOCK TABLES语句进行锁表
--trim BIT_XORACCUM 模式下的 TRIM() VARCHAR
--[no]unique-checks 启用唯一键检查 ( SET UNIQUE_CHECKS=1 )
--user 用于连接的用户
--verbose 打印同步操作的结果
--version 显示版本
--[no]version-check 版本检查
--wait 指定存在主从复制延迟时从库可以等待多长时间追上主库,如果超过时间依然存在延迟就中止退出
--where WHERE 子句用于限制同步到表的一部分
--[no]zero-chunk 为具有零或零等值的行添加块

最佳实践

同步单个表

注意,同步时候两台机器不能是主从关系。第一DSN为源库,第二个DSN为被同步库

将192.168.6.55机器上的test_db.test_t1表同步至192.168.6.129机器

$ pt-table-sync --execute h=192.168.6.55,u=root,p=,P=3306,D=test_db,t=test_t1 h=192.168.6.129,p=test,u=test,P=3306

同步单个库

注意,同步时候两台机器不能是主从关系。第一DSN为源库,第二个DSN为被同步库

$ pt-table-sync --execute h=192.168.6.55,u=root,p=,P=3306 h=192.168.6.129,u=test,p=test --databases test_db

此时如果有表不存在,则会报错

Table test_db.checksums does not exist on P=3306,h=192.168.6.129,p=...,u=test  while doing test_db.checksums on 192.168.6.129

此时只需手动建表即可

同步所有库表

注意,同步时候两台机器不能是主从关系。第一DSN为源库,第二个DSN为被同步库

$ pt-table-sync --execute h=192.168.6.55,u=root,p=,P=3306 h=192.168.6.129,u=test,p=test

主从复制同步从库

同步test_db.checksums中记录的数据不一致的表。该表中的数据是由pt-table-checksum工具检测出来的

$ pt-table-sync --execute --replicate 'test_db.checksums' --sync-to-master h=192.168.6.55,P=3307,u=root,p=

本文完 😃 下章节将介绍Percona Toolkit 神器全攻略(性能类)


Enjoy GreatSQL 😃

关于 GreatSQL

GreatSQL是适用于金融级应用的国内自主开源数据库,具备高性能、高可靠、高易用性、高安全等多个核心特性,可以作为MySQL或Percona Server的可选替换,用于线上生产环境,且完全免费并兼容MySQL或Percona Server。

相关链接: GreatSQL社区 Gitee GitHub Bilibili

GreatSQL社区:

社区博客有奖征稿详情:https://greatsql.cn/thread-100-1-1.html

技术交流群:

微信:扫码添加GreatSQL社区助手微信好友,发送验证信息加群