check mysql slave状态并跳过相应错误(守护模式)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
我的博客已迁移到xdoujiang.com请去那边和我交流
一、具体代码
#!/bin/bash
#--------------------------------------------------
#Author:jimmygong
#Email:jimmygong@taomee.com
#FileName:checkslave.sh
#Function: 
#Version:1.0 
#Created:2016-01-01
#--------------------------------------------------
if  [[ ` id  -u` - ne  0 ]]
then
     echo  "script need root"
     exit  1
fi
function  usage ()
{
     echo  "Usage:bash $0 start"
     echo  "Usage:bash $0 stop"
}
if  [[ $ # -ne 1 ]]
then
     usage
     exit  1
fi
#根据情况修改变量信息
mysqluser= "root"
mysqlpass= "123456"
mysqlport=3398
mysqlsocket= "/opt/mysql/$mysqlport/$mysqlport.sock"
currdate=$( date  +%Y%m%d)
logpath= "/root/checkslave"
logfile=$logpath/${currdate}
#各个错误代码解释
1158网络错误,出现读错误,请检查网络连接状况
1159网络错误,读超时,请检查网络连接状况
1008数据库不存在,删除数据库失败
1007数据库已存在,创建数据库失败
1062字段值重复,入库失败
1452不能删除或更新父行,外键约束失败
PS:1452这个根据情况跳过错误
allerror=(1158 1159 1008 1007 1062 1452)
sleeptime=60
[[ -d $logpath ]] ||  mkdir  $logpath
function  echosucc ()
{
     succstatus= "[ Ok ]"
     printf  "\033[32m $succstatus $* \033[0m\n"
}
function  mysqlconn ()
{
     comm =$1
     mysql -u${mysqluser} -p${mysqlpass} -S ${mysqlsocket} -e  "$comm"
}
function  checkrun ()
{
         esport=$( lsof  -i:$mysqlport| wc  -l)
     if  [[ $esport -lt 2 ]]
     then
     echo  "Mysql Server Failed"
     exit  1
         fi
}
function  statuserror ()
{
     for ((i=0;i<${ #allerror[*]};i++))
     do
         if  [[  "$1"  ==  "${allerror[$i]}"  ]]
         then
             mysqlconn  "stop slave;set global sql_slave_skip_counter=1;start slave;"
         else 
             echo  "$(date +" %m-%d %H:%M:%S ") Mysql Slave Failed $1"  >> $logfile
         fi
     done
}
function  checkslave ()
{
     status=($(mysqlconn  "show slave status\G" | egrep  -i  "_running|last_errno" | awk  '{print $NF}' ))
     if  [[  "${status[0]}"  ==  "Yes"  ]] && [[  "${status[1]}"  ==  "Yes"  ]]
     then
         echo  "$(date +" %m-%d %H:%M:%S ") Mysql Slave Ok"  >> $logfile
     else
         statuserror ${status[2]}
     fi
}
function  start () 
{
     echosucc  "Starting Monitor"
     while  true
     do
         checkrun
         checkslave
         sleep  $sleeptime
     done
}
function  stop () 
{
     echosucc  "Stop Monitor"
     echo  $$ >  "$logpath/pidfile"
     for  PID  in  $( ps  -eo pid, command | grep  "$0" | grep  - v  grep | awk  '{print $1}' );
     do
         [[ $PID != $( cat  $logpath /pidfile ) ]] &&  kill  -s TERM $PID >&  /dev/null
     done
}
case  $1  in
     start)
     start &
     ;;
     stop)
     stop
     ;;
     *)
     usage
     ;;
esac
 
二、相关日志都记录在
cat  checkslave /20160102  | more
01-02 21:19:10 Mysql Slave Failed 1452
01-02 21:19:10 Mysql Slave Failed 1452
01-02 21:19:10 Mysql Slave Failed 1452
01-02 21:19:10 Mysql Slave Failed 1452
01-02 21:19:10 Mysql Slave Failed 1452
01-02 21:34:58 Mysql Slave Ok
01-02 21:35:58 Mysql Slave Ok
01-02 21:36:59 Mysql Slave Ok
01-02 21:37:59 Mysql Slave Ok
 
三、相关进程
ps  -ef | grep  -w checkslave.sh
root     12260     1  0 21:34 pts /2     00:00:00  bash  checkslave.sh start
 
四、相关启动和关闭
bash  checkslave.sh start
  [ Ok ] Starting Monitor
bash  checkslave.sh stop
  [ Ok ] Stop Monitor









本文转自 xdoujiang 51CTO博客,原文链接:http://blog.51cto.com/7938217/1729738,如需转载请自行联系原作者
相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
5月前
|
Prometheus 监控 关系型数据库
数据库同步革命:MySQL GTID模式下主从配置的全面解析
数据库同步革命:MySQL GTID模式下主从配置的全面解析
616 0
|
3月前
|
SQL 关系型数据库 MySQL
MySQL的match WITH QUERY EXPANSION 模式是什么?如何使用?
【8月更文挑战第29天】MySQL的match WITH QUERY EXPANSION 模式是什么?如何使用?
61 4
|
4月前
|
分布式计算 DataWorks 关系型数据库
MaxCompute操作报错合集之配置mysql数据源querysql模式,同步到MC时遇到报错,该怎么处理
MaxCompute是阿里云提供的大规模离线数据处理服务,用于大数据分析、挖掘和报表生成等场景。在使用MaxCompute进行数据处理时,可能会遇到各种操作报错。以下是一些常见的MaxCompute操作报错及其可能的原因与解决措施的合集。
|
5月前
|
JSON 关系型数据库 MySQL
实时计算 Flink版产品使用问题之在使用CDAS语法同步MySQL数据到Hologres时,如果开启了字段类型宽容模式,MySQL中的JSON类型会被转换为什么
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
5月前
|
分布式计算 DataWorks 关系型数据库
DataWorks操作报错合集之数据源同步时,使用脚本模式采集mysql数据到odps中,使用querySql方式采集数据,在脚本中删除了Reader中的column,但是datax还是报错OriginalConfPretreatmentUtil - 您的配置有误。如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
6月前
|
传感器 人工智能 前端开发
JAVA语言VUE2+Spring boot+MySQL开发的智慧校园系统源码(电子班牌可人脸识别)Saas 模式
智慧校园电子班牌,坐落于班级的门口,适合于各类型学校的场景应用,班级学校日常内容更新可由班级自行管理,也可由学校统一管理。让我们一起看看,电子班牌有哪些功能呢?
552 4
JAVA语言VUE2+Spring boot+MySQL开发的智慧校园系统源码(电子班牌可人脸识别)Saas 模式
|
4月前
|
SQL 关系型数据库 MySQL
You have an error in your SQL syntax;check the manual that corresponds to you Mysql server version
You have an error in your SQL syntax;check the manual that corresponds to you Mysql server version
|
5月前
|
SQL 存储 关系型数据库
1064 - You have an error in your SQL syntax; check the manual that corresponds to your MySQL server
1064 - You have an error in your SQL syntax; check the manual that corresponds to your MySQL server
|
5月前
|
关系型数据库 MySQL 数据库
深入OceanBase分布式数据库:MySQL 模式下的 SQL 基本操作
深入OceanBase分布式数据库:MySQL 模式下的 SQL 基本操作
|
5月前
|
SQL 关系型数据库 MySQL
You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version
You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version