python编写脚本应用实例

这里主要记录工作中应用python编写脚本的实例。由于shell脚本操作数据库（增、删、改、查）并不是十分直观方便，故这里采用python监控mysql状态，然后将状态保存到数据库中，供前台页面进行调用显示。

1、监控mysql主从复制状态

1）创建保存主从复制状态的表

CREATE TABLE `slave_status` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `slave_host` char(15) NOT NULL,          #从库主机ip
  `master_host` char(15) NOT  NULL,        #主库主机ip
  `value` int(11) NOT NULL,                #返回值，2表示正常，0表示不正常
  `created_date` datetime NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8；

2）python脚本

# coding:utf8
import mysql.connector
import time

#############################################################
#从库主机信息
#############################################################
hosts = [\'192.168.245.131\',\'192.168.245.132\']
dbuser = \'root\'
password = \'root\'
port = 3306
#############################################################
#保存数据的主机信息
#############################################################
save_host = \'192.168.245.129\'
save_dbuser = \'root\'
save_password = \'root\'
save_port = 3306

query = "show slave status"

for host in hosts:
    try:
        conn_slave = mysql.connector.connect(host=host,port=port,user=dbuser,passwd=password,charset=\'utf8\')
        conn_save = mysql.connector.connect(host=save_host,port=save_port,user=save_dbuser,passwd=save_password,charset=\'utf8\')
        cur_slave = conn_slave.cursor()
        cur_save = conn_save.cursor()
        cur_slave.execute(query)
        results = cur_slave.fetchall()

        master_host = results[0][1]
        if results[0][10]==\'Yes\' and results[0][11] == \'Yes\':
            insert_sql = "insert into a.slave_status(slave_host,master_host,value,created_date) values(\'%s\',\'%s\',2,NOW());" % (host,master_host)
        else:
            insert_sql = "insert into a.slave_status(slave_host,master_host,value,created_date) values(\'%s\',\'%s\',0,NOW());" % (host,master_host)
        cur_save.execute(insert_sql)
        conn_save.commit()
    except Exception as e:
        raise str(e)
    finally:
        cur_save.close()
        cur_slave.close()
        conn_save.close()
        conn_slave.close()