Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1724990
  • 博文数量: 362
  • 博客积分: 10587
  • 博客等级: 上将
  • 技术积分: 4098
  • 用 户 组: 普通用户
  • 注册时间: 2009-09-10 18:15
文章分类

全部博文(362)

文章存档

2014年(1)

2013年(58)

2011年(115)

2010年(112)

2009年(76)

分类: Python/Ruby

2011-05-23 16:29:53

import os
import sys
import MySQLdb

def getStatus(conn):
    query = " SHOW SLAVE STATUS "
            
    # print query
    cursor = conn.cursor()
    cursor.execute(query)
    result = cursor.fetchall()
    return result[0]

def resolve(conn):
    cursor = conn.cursor()
    query1 = "set global sql_slave_skip_counter=1"
    query2 = "START SLAVE"
    query3 = "SHOW SLAVE STATUS"
    
    cursor.execute(query1)
    cursor.execute(query2)
    cursor.execute(query3)
    conn.commit()
    
if __name__ == '__main__':
    conn = MySQLdb.connect(read_default_file="~/.my.cnf", db="", port=3306, charset="utf8")
    status = getStatus(conn)
    print "Master_Log_File: %s" % status[5]
    print "Read_Master_Log_Pos: %s" % status[6]
    print "Seconds_Behind_Master: %s" % status[-1]

    if status[32] is None:
        resolve(conn)
    else:
        print 'resolved'
阅读(1996) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~