刚写的一个自动跳过从库复制SQL进程错误脚本

Hellex

首先，找一台监控机，确保有登陆各从库查看复制状态的权限。
比如在一台主机名为Admin的机器上，编写监控脚本slavedm.sh，保存如 /server/daemon/slavedm.sh

slavedm.sh源码

1. 
   
2. #!/bin/sh
   
3. #
   
4. # Slave Daemon
   
5. # @version 1.0
   
6. # @author Hellex <[email]Hellex@live.com[/email]>
   
7. #
   
8. 
   
9. #从库服务器配置，分别是主机名，端口，用户名，密码，请一一对应
   
10. mysql_host=("db2" "db3" "db4" "db5" "db6" "db7" "db8" "db9" "db10" "db11" "db12" "db13")
    
11. mysql_port=(3306 3306 3306 3306 3306 3306 3406 3306 3307 3406 3309 3310)
    
12. mysql_user=("dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser" "dmuser")
    
13. mysql_password=("dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword" "dmpassword")
    
14. 
    
15. #loop for checking
    
16. len=${#mysql_host[*]}
    
17. i=0
    
18. while  [ $i -lt $len ]
    
19. do
    
20.     #get slave status
    
21.     status=`/usr/local/webserver/mysql/bin/mysql  -h${mysql_host[$i]} -u${mysql_user[$i]} -p${mysql_password[$i]} -P${mysql_port[$i]} -e"SHOW SLAVE STATUS\G"`
    
22. 
    
23.     #check SQL Thread
    
24.     if (echo "$status"|egrep "Slave_IO_Running: *Yes" 2>&1 > /dev/null) && (echo "$status"|egrep "Slave_SQL_Running: *No" 2>&1 > /dev/null)
    
25.     then
    
26. 
    
27.        #log error
    
28.        sql_error=`echo "$status"|egrep "Last_SQL_Error:" | awk -F 'Last_SQL_Error:' '{printf $2}'`
    
29.        sql_erroro=`echo "$status"|egrep "Last_SQL_Errno:" | awk -F 'Last_SQL_Errno:' '{printf $2}'`
    
30.        echo `date +%y%m%d%H%M%S`"    "${mysql_host[$i]}:${mysql_port[$i]}"    "${sql_erroro}"    "${sql_error} >> /server/daemon/slavedm.log
    
31. 
    
32.        #stop slave
    
33.        /usr/local/webserver/mysql/bin/mysql  -h${mysql_host[$i]} -u${mysql_user[$i]} -p${mysql_password[$i]} -P${mysql_port[$i]} -e"STOP SLAVE" 2>&1 > /dev/null
    
34. 
    
35.        #skip error
    
36.        /usr/local/webserver/mysql/bin/mysql  -h${mysql_host[$i]} -u${mysql_user[$i]} -p${mysql_password[$i]} -P${mysql_port[$i]} -e"SET GLOBAL SQL_SLAVE_SKIP_COUNTER = 1" 2>&1 > /dev/null
    
37. 
    
38.        #start slave
    
39.        /usr/local/webserver/mysql/bin/mysql  -h${mysql_host[$i]} -u${mysql_user[$i]} -p${mysql_password[$i]} -P${mysql_port[$i]} -e"START SLAVE" 2>&1 > /dev/null
    
40. 
    
41.     fi
    
42.     let i++
    
43. done
    

复制代码

slavedm.sh脚本做的工作就是检查从库复制的IO及SQL进程，当IO进程正常，SQL不正常的时候，说明SQL执行有错误，这时候脚本自动把错误记录下来。
格式如:yymmddHHMMSS    主机名:端口    错误代码    错误信息
这些错误会记录到slavedm.log文件
记录完错误之后，slavedm.sh执行跳过错误语句
/usr/local/webserver/mysql/bin/mysql工具的地址请根据自己的情况更改，这里就不设为变量了。


给slavedm.sh添加可执行权限

1. 
   
2. #chmod +x /server/daemon/slavedm.sh
   

复制代码

我们来做一下测试
登陆主库，在test库建一个test3表，并给它加一个index

1. 
   
2. mysql> use test
   
3. Database changed
   
4. 
   
5. mysql> create table test3 (id int(10));
   
6. Query OK, 0 rows affected (0.00 sec)
   
7. 
   
8. mysql> alter table test3 add index id(id);
   
9. Query OK, 0 rows affected (0.01 sec)
   
10. Records: 0  Duplicates: 0  Warnings: 0
    

复制代码

登陆其中一台从库，假如db11

1. 
   
2. mysql> use test
   
3. Database changed
   
4. 
   
5. mysql> show tables;
   
6. +----------------+
   
7. | Tables_in_test |
   
8. +----------------+
   
9. | test1          |
   
10. | test2          |
    
11. | test3          |
    
12. +----------------+
    
13. 3 rows in set (0.00 sec)
    
14. [color=Blue]可以看到test3出现在test库里，我们把它的索引删除，然后再回到主库删除索引，以引发复制错误[/color]
    
15. mysql> alter table test3 drop index id;
    
16. Query OK, 0 rows affected (0.01 sec)
    
17. Records: 0  Duplicates: 0  Warnings: 0
    

复制代码

回到主库

1. 
   
2. mysql> alter table test3 drop index id;
   
3. Query OK, 0 rows affected (0.05 sec)
   
4. Records: 0  Duplicates: 0  Warnings: 0
   

复制代码

再看db11

1. 
   
2. mysql> show slave status\G
   
3. 
   
4. ......省略其他部份
   
5.              Slave_IO_Running: Yes
   
6.             Slave_SQL_Running: No
   
7. 
   
8.                Last_SQL_Errno: 1091
   
9.                Last_SQL_Error: Error 'Can't DROP 'id'; check that column/key exists' on query. Default database: 'test'. Query: 'alter table test3 drop index id'
   
10. 1 row in set (0.00 sec)
    
11. 
    
12. [color=Blue]可以看到复制错误了[/color]
    

复制代码

然后我们到监控机执行slavedm.sh

1. 
   
2. #/server/daemon/slavedm.sh
   

复制代码

再看db11

1. 
   
2. mysql> show slave status\G
   
3. 
   
4. ......省略其他部份
   
5.              Slave_IO_Running: Yes
   
6.             Slave_SQL_Running: Yes
   
7. [color=Blue]可以看到复制恢复正常了[/color]
   

复制代码

看监控日志

1. 
   
2. #cat /server/daemon/slavedm.log
   
3. 081130192001    db11:3306     1091     Error 'Can't DROP 'id'; check that column/key exists' on query. Default database: 'test'. Query: 'alter table test3 drop index id'
   

复制代码

说明slavedm.sh脚本功能很正常。


我们把slavedm.sh添加到crontab，每5分钟执行一次

1. 
   
2. #crontab -e
   

复制代码

添加以下内容

1. 
   
2. #slave daemon
   
3. 0-55/5 * * * * /server/daemon/slavedm.sh
   

复制代码

[ 本帖最后由 Hellex 于 2008-11-30 19:22 编辑 ]

yueliangdao0608

IO 错误就不行了。

Hellex

原帖由 yueliangdao0608 于 2008-11-30 22:06 发表
IO 错误就不行了。

这只是写了对SQL进程错误的处理

其他的比如延时监控之类的可以照着改

枫影谁用了

不错。根据需求改改就很好了