Maple

×××××

日志

Drbd+heartbeat+mysql replication来构建mysql的高可用性

mysql replication出错自动检测的脚本

2009-02-13 13:36:56| 分类： MySQL Replicatio | 标签： |字号大中小订阅

修改版：

#!/usr/local/bin/perl -w
#
# fix mysql replication if it encounters a problem
# Useage：perl fix_repl.pl ip1 ip2 ip3

$|=1;    # unbuffer stdout
use strict;
use DBIx::DWIW;
use Mail::Mailer;
my $ip;
foreach $ip (@ARGV) {
&fixdb($ip);
}

exit;

sub fixdb()
{
my $host = shift || 'localhost';
my $conn = DBIx::DWIW->;Connect(
DB =>; "test",
User =>; "sqlmon",
Pass =>; '!@#$%^&*()',
       Host =>; $host,
Port   =>; 3306) or die "Couldn't connect to database!";

print "checking $host ... \n";
my $info = $conn->;Hash("SHOW SLAVE STATUS") or die $@;
my @version = $conn->;Array("SHOW VARIABLES LIKE 'Version'");
my $fix_cmd;
my $start_cmd;
# slave not start
if ($info->;{Slave_IO_Running} eq 'No' and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START";
}
# 4.0.0 - 4.0.2
elsif ($version[1] =~ /^4\.0\.[012]/ and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START SQL_THREAD";
}
# 4.0.3 - 4.0.xx, 4.1.xx.   Don't know what 5.0 will be like.
elsif ($version[1] =~ /^4\.[01]\./ and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET GLOBAL SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START SQL_THREAD";
}
# things are okay or unknown version?
else
{
print "GOOD\n";
}
if ($info->;{Slave_IO_Running} eq 'No'   or   $info->;{Slave_SQL_Running} eq 'No' ){
&mailtoadmin($info,$host);
print "FIXING ... ";
$conn->;Execute($fix_cmd);
$conn->;Execute($start_cmd);
print "DONE\n";
}

}

sub mailtoadmin(){
       my $body=shift;
my $host = shift;
       my @MailTo=("xxxx\@yyyy.com");
       my $subject = "Mysql Self fix replication on $host ";
my $mailer = Mail::Mailer->;new() or die $@;
$mailer->;open({ From =>; $host,
To    =>; \@MailTo,
Subject =>; $subject,
})or die "Can't open: $!\n";
# while ( my ($key, $value) = each(%$body) ) {
#        print $mailer "$key =>; $value\n";
# }
print $mailer <<MAILCONTENT;

*************************** show slave status***************************

Master_Host =>;   $body->;{'Master_Host'}
Master_User =>;   $body->;{'Master_User'}
Master_Port =>;   $body->;{'Master_Port'}
Connect_retry =>;   $body->;{'Connect_retry'}
Master_Log_File =>;   $body->;{'Master_Log_File'}
Read_Master_Log_Pos =>;$body->;{'Read_Master_Log_Pos'}
Relay_Log_File =>;   $body->;{'Relay_Log_File'}
Relay_Log_Pos =>;   $body->;{'Relay_Log_Pos'}
Relay_Master_Log_File =>;$body->;{'Relay_Master_Log_File'}
Slave_IO_Running =>;$body->;{'Slave_IO_Running'}
Slave_SQL_Running =>;$body->;{'Slave_SQL_Running'}
Replicate_do_db =>; $body->;{'Replicate_do_db'}
Replicate_ignore_db =>;$body->;{'Replicate_ignore_db'}
Last_errno =>; $body->;{'Last_errno'}
Last_error =>; $body->;{'Last_error'}
Skip_counter =>; $body->;{'Skip_counter'}
Exec_master_log_pos =>; $body->;{'Exec_master_log_pos'}
Relay_log_space =>; $body->;{'Relay_log_space'}
MAILCONTENT
$mailer->;close();
}

原版：

#!/usr/local/bin/perl -w
#
# fix mysql replication if it encounters a problem
# Useage：perl fix_repl.pl ip1 ip2 ip3

$|=1;    # unbuffer stdout
use strict;
use DBIx::DWIW;
use Mail::Mailer;
my $ip;
foreach $ip (@ARGV) {
&fixdb($ip);
}

exit;

sub fixdb()
{
my $host = shift || 'localhost';
my $conn = DBIx::DWIW->;Connect(
DB =>; "test",
User =>; "sqlmon",
Pass =>; '!@#$%^&*()',
      Host =>; $host,
Port  =>; 3306) or die "Couldn't connect to database!";

print "checking $host ... \n";
my $info = $conn->;Hash("SHOW SLAVE STATUS") or die $@;
my @version = $conn->;Array("SHOW VARIABLES LIKE 'Version'");
my $fix_cmd;
my $start_cmd;
# slave not start
if ($info->;{Slave_IO_Running} eq 'No' and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START";
}
# 4.0.0 - 4.0.2
elsif ($version[1] =~ /^4\.0\.[012]/ and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START SQL_THREAD";
}
# 4.0.3 - 4.0.xx, 4.1.xx.  Don't know what 5.0 will be like.
elsif ($version[1] =~ /^4\.[01]\./ and $info->;{Slave_SQL_Running} eq 'No')
{
$fix_cmd = "SET GLOBAL SQL_SLAVE_SKIP_COUNTER = 1";
$start_cmd = "SLAVE START SQL_THREAD";
}
# things are okay or unknown version?
else
{
print "GOOD\n";
}
if ($info->;{Slave_IO_Running} eq 'No'  or  $info->;{Slave_SQL_Running} eq 'No' ){
&mailtoadmin($info,$host);
print "FIXING ... ";
$conn->;Execute($fix_cmd);
$conn->;Execute($start_cmd);
print "DONE\n";
}

}

sub mailtoadmin(){
      my $body=shift;
my $host = shift;
      my @MailTo=("xxxx\@yyyy.com");
      my $subject = "Mysql Self fix replication on $host ";
my $mailer = Mail::Mailer->;new() or die $@;
$mailer->;open({ From =>; $host,
To    =>; \@MailTo,
Subject =>; $subject,
})or die "Can't open: $!\n";
# while ( my ($key, $value) = each(%$body) ) {
#       print $mailer "$key =>; $value\n";
# }
print $mailer <<MAILCONTENT;

*************************** show slave status***************************

Master_Host =>;  $body->;{'Master_Host'}
Master_User =>;  $body->;{'Master_User'}
Master_Port =>;  $body->;{'Master_Port'}
Connect_retry =>;  $body->;{'Connect_retry'}
Master_Log_File =>;  $body->;{'Master_Log_File'}
Read_Master_Log_Pos =>;$body->;{'Read_Master_Log_Pos'}
Relay_Log_File =>;  $body->;{'Relay_Log_File'}
Relay_Log_Pos =>;  $body->;{'Relay_Log_Pos'}
Relay_Master_Log_File =>;$body->;{'Relay_Master_Log_File'}
Slave_IO_Running =>;$body->;{'Slave_IO_Running'}
Slave_SQL_Running =>;$body->;{'Slave_SQL_Running'}
Replicate_do_db =>; $body->;{'Replicate_do_db'}
Replicate_ignore_db =>;$body->;{'Replicate_ignore_db'}
Last_errno =>; $body->;{'Last_errno'}
Last_error =>; $body->;{'Last_error'}
Skip_counter =>; $body->;{'Skip_counter'}
Exec_master_log_pos =>; $body->;{'Exec_master_log_pos'}
Relay_log_space =>; $body->;{'Relay_log_space'}
MAILCONTENT
$mailer->;close();
}

评论这张

转发至微博

0人 | 分享到：

阅读(287)| 评论(0)| 引用 (0) |举报

Drbd+heartbeat+mysql replication来构建mysql的高可用性

MySQL的双机拷贝备份(Replication)的配置

历史上的今天

this.p={  m:2,
              b:2,
              id:'fks_085075080094088064081085095095085086088075086081087070085',
              blogTitle:'mysql replication出错自动检测的脚本',
              blogAbstract:'<P\>修改版：</P\>\r\n<P\>#!/usr/local/bin/perl -w<BR\>#<BR\># fix mysql replication if it encounters a problem<BR\># Useage：perl fix_repl.pl ip1 ip2 ip3<BR\><BR\>$|=1;    # unbuffer stdout<BR\>use strict;<BR\>use DBIx::DWIW;<BR\>use Mail::Mailer;<BR\>my $ip;<BR\>foreach $ip (@ARGV) {<BR\>&fixdb($ip);<BR\>}<BR\><BR\>exit;<BR\><BR\>sub fixdb()<BR\>{<BR\>my $host = shift || \'localhost\';<BR\>my $conn = DBIx::DWIW->;Connect(</P\>',
              blogTag:'',
              blogUrl:'blog/static/109827151200911313656803',
              isPublished:1,
              istop:false,
              type:0,
              modifyTime:0,
              publishTime:1234503416803,
              permalink:'blog/static/109827151200911313656803',
              commentCount:0,
              mainCommentCount:0,
              recommendCount:0,
              bsrk:-100,
              publisherId:0,
              recomBlogHome:false,
              attachmentsFileIds:[],
              vote:{},
              groupInfo:{},
              friendstatus:'none',
              followstatus:'unFollow',
              pubSucc:'',
              visitorProvince:'未设置',
              visitorCity:'未设置',
              postAddInfo:{},
              mset:'000',
              mcon:'',
              srk:-100,
              remindgoodnightblog:false,
              isBlackVisitor:false,
              isShowYodaoAd:false,
              hostIntro:'',
              hmcon:'',
              lofter_single:'<a hidefocus="true" target="_blank" href="http://www.lofter.com/touch"><img onload="var nimg = new Image(); nimg.src=\'http://blog.163.com/newpage/images/analyse.png?lofter_single&t=\'+new Date().getTime()" border="0" src="http://b2.bst.126.net/newpage/images/lofter_single4.jpg"/></a>'
            }

{list a as x}
    {if !!x}
    <div class="iblock nbw-fce nbw-f40">
      <a class="fc03 noul" target="_blank" hidefocus="true" href="http://blog.163.com/${x.visitorName}/">
      {if x.visitorName==visitor.userName}
      <img alt="${x.visitorNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.visitorName)}&r=${visitor.imageUpdateTime}"/>
      {else}
      <img alt="${x.visitorNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.visitorName)}"/>
      {/if}
      </a>
      <div class="cwd vname thide">
        {if x.moveFrom=='wap'}
          <a class="noul pnt" target="_blank" href="http://blog.163.com/services/wapblog.html?frompersonalbloghome"><span title="来自网易手机博客" class="iblock wapIcon"> </span></a>
        {elseif x.moveFrom=='iphone'}
          <a class="noul pnt" target="_blank"><span title="来自iPhone客户端" class="iblock iphoneIcon"> </span></a>
        {elseif x.moveFrom=='android'}
          <a class="noul pnt" target="_blank"><span title="来自Android客户端" class="iblock androidIcon"> </span></a>
        {elseif x.moveFrom=='mobile'}
          <a class="noul pnt" target="_blank" href="http://blog.163.com/services/emsblog.html?frompersonalbloghome"><span title="来自网易短信写博" class="iblock wapIcon"> </span></a>
        {/if}
        <a class="fc03 m2a"  target="_blank" hidefocus="true" href="http://blog.163.com/${x.visitorName}/">
          ${fn(x.visitorNickname,8)|escape}
        </a>
      </div>
    </div>
    {/if}
    {/list}

<#--最新日志，群博日志--> <#--推荐日志-->

<p class="fc06">推荐过这篇日志的人：</p>
    <div>
      {list a as x}
      {if !!x}
      <div class="iblock nbw-fce nbw-f40">
        <a class="fc03 noul" target="_blank" hidefocus="true" href="http://blog.163.com/${x.recommenderName}/">
        <img alt="${x.recommenderNickname|escape}" onerror="this.src=location.f40" class="cwd bdwa bdc0" src="${fn1(x.recommenderName)}"/>
        </a>
        <div class="cwd thide">
          <a class="fc03 m2a" target="_blank" hidefocus="true" href="http://blog.163.com/${x.recommenderName}/">
            ${fn(x.recommenderNickname,6)|escape}
          </a>
        </div>
      </div>
      {/if}
      {/list}
    </div>
    {if !!b&&b.length>0}
    <p  class="fc06">他们还推荐了：</p>
    <ul>
    {list b as y}
      {if !!y}
        <li class="rrb"><span class="iblock">·</span><a class="fc03 m2a" target="_blank" href="http://blog.163.com/${y.recommendBlogPermalink}/?from=blog/static/109827151200911313656803">${y.recommendBlogTitle|escape}</a></li>
      {/if}
    {/list}
    </ul>
    {/if}

<#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--相关文章--> <#--历史上的今天--> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->

页脚

公司简介 - 联系方法 - 招聘信息 - 客户服务 - 隐私政策 - 博客风格 - 手机博客 - VIP博客 - 订阅此博客

Maple

导航

日志

mysql replication出错自动检测的脚本

历史上的今天

相关文章

最近读者

评论

页脚