开发者社区> bisal> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

MySQL系统运行状态实时监控(python版本)

简介: 昨天的文章,用shell写了一个简单的MySQL系统运行状态实时监控的模版,《MySQL系统运行状态实时监控(shell版本)》,对于这种操作,任何语言都可以完成,今儿就用python写一下,写的不优雅的地方,请各位指正。
+关注继续查看

昨天的文章,用shell写了一个简单的MySQL系统运行状态实时监控的模版,《MySQL系统运行状态实时监控(shell版本)》,对于这种操作,任何语言都可以完成,今儿就用python写一下,写的不优雅的地方,请各位指正。


首先,为了让python能连接MySQL数据库,需要一些第三方的库,由于我用的是python 2.3版本,因此可以使用mysqldb,(若是python 3.x,则可以使用PyMySQL),可以从以下链接下载压缩,目前最新版本是1.2.5,

https://pypi.python.org/pypi/MySQL-python/1.2.3



如果不确定本机是否安装了,可以使用,

python

>> import MySQLdb


看下是否报错,若提示了,

ImportError: No module named MySQLdb

则表示未安装。


解压MySQL-python-1.2.3.tar.gz,



进入目录,执行以下命令,完成mysqldb的安装,

python setup.py install


接下来开始coding,首先定义一个枚举类,方便常量调用,此处为五个状态参数,

def enum(**enums):

return type('Enum', (), enums)


Status=enum(QPS="queries", Commit="com_commit",

Rollback="com_rollback", Threads_con="Threads_connected",

Threads_run="Threads_running")


python连接数据库,确实比java这些语言,要简单些,

dbConn=MySQLdb.connect(

host='x.x.x.x',

port=3306,

user='bisal',

passwd='xxxxx',

db='mysql')

cursor=dbConn.cursor()


比如我要检索QPS这个参数,执行以下SQL,由于是肯定只返回一条数据,所以用了fetchone()函数,为了只要返回值,使用str[a:b]进行了字符串截取。

sql='show global status like \'' + Status.QPS + '\''

cursor.execute(sql)

result=cursor.fetchone()

str= ''.join(result)

q=str[len(Status.QPS):len(str)]


接下来就可以格式化打印,同样输出10次,重新打印表头,显示sleep一秒,

if (count==0):

print "|QPS        |Commit     |Rollback   |TPS        |Threads_con  |Threads_run |"

print "------------------------------------------------------------------------------"

if (count>=10):

count=0

print "------------------------------------------------------------------------------"

print "|QPS        |Commit     |Rollback   |TPS        |Threads_con  |Threads_run |"

print "------------------------------------------------------------------------------"

print "|%-10s |%-10s |%-10s |%-10s |%-12s |%-12s|" % (q,c,r,c+r,tc,tr)

else:

print "|%-10s |%-10s |%-10s |%-10s |%-12s |%-12s|" % (q,c,r,c+r,tc,tr)

count+=1

time.sleep(1)


另外,记得需要关闭数据库连接,

cursor.close()

dbConn.close()


整个流程,其实很简单,就是执行show status语句,进行一些字符串处理,格式化输出,以上完整代码,可以下载:

https://github.com/bisal-liu/mysql/blob/master/mysql_per_monitor_1.py


要说可以优化,就是上面这种方法中,对于每一个状态参数,都要执行一次show status,有些浪费,可以一次执行,多次解析,使用IN子句,实现执行一次SQL,返回不同参数,

sql='show global status where variable_name in (\'' + Status.QPS + '\',\'' + Status.Commit \

+ '\',\'' + Status.Rollback + '\',\'' + Status.Threads_con + '\',\'' + Status.Threads_run + '\')'


由于返回不止一条记录,因此需要使用for,if中根据字符串做匹配,以下写法中,

1. 若使用了''.join(line),则需要使用q=k1[len(Status.QPS):len(k1)]截取字符串。

2. 若使用了str(line),则需要使用q=k2.split('\'')[3]截取字符串。

for line in result:

k1=''.join(line).lower()

k2=str(line).lower()


if (Status.QPS in k1):

q=k1[len(Status.QPS):len(k1)]

elif (Status.Commit in k1):

c=k1[len(Status.Commit):len(k1)]

elif (Status.Rollback in k1):

r=k1[len(Status.Rollback):len(k1)]

elif (Status.Threads_con in k1):

tc=k1[len(Status.Threads_con):len(k1)]

elif (Status.Threads_run in k1):

tr=k1[len(Status.Threads_run):len(k1)]


if (Status.QPS in k2):

q=k2.split('\'')[3]

elif (Status.Commit in k2):

c=k2.split('\'')[3]

elif (Status.Rollback in k2):

r=k2.split('\'')[3]

elif (Status.Threads_con in k2):

tc=k2.split('\'')[3]

elif (Status.Threads_run in k2):

tr=k2.split('\'')[3]


以上完整代码,可以下载,

https://github.com/bisal-liu/mysql/blob/master/mysql_per_monitor_2.py


以上两种写法,效果一样,

1. 每隔1秒,刷新一次,

2. 每隔10次,重新打印表头,



如果您觉得此篇文章对您有帮助,欢迎关注微信公众号:bisal的个人杂货铺,您的支持是对我最大的鼓励!共同学习,共同进步:)

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Python:mysql-connector-python模块对MySQL数据库进行增删改查
Python:mysql-connector-python模块对MySQL数据库进行增删改查
0 0
Python:mysql-replication监控MySQL的binlog变动
Python:mysql-replication监控MySQL的binlog变动
0 0
Python:使用 mysqlsmom 模块实时同步MySQL数据到ElasticSearch
Python:使用 mysqlsmom 模块实时同步MySQL数据到ElasticSearch
0 0
Python连接MySQL数据库(简单便捷)
Python连接MySQL数据库(简单便捷)
0 0
Python与MySQL数据库的交互
Python与MySQL数据库的交互
0 0
进阶——python——数据库处理之MySQL
进阶——python——数据库处理之MySQL
0 0
windows python flask与mysql数据库写入查询
windows python flask与mysql数据库写入查询
0 0
python接口自动化(三十八)-python操作mysql数据库(详解)
现在的招聘要求对QA人员的要求越来越高,测试的一些基础知识就不必说了,来说测试知识以外的,会不会一门或者多门开发与语言,能不能读懂代码,会不会Linux,会不会搭建测试系统,会不会常用的数据库,会不会SQL等等,因此我们这篇文章来讲解如何用python语言操作mysql数据库。
0 0
Python 连接MariaDB的一些小问题Cant connect to MySQL server
Python 连接MariaDB的一些小问题Cant connect to MySQL server
0 0
Python学习笔记二十天(MySQL数据库)
Python学习笔记第二十天讲解数据库查询操作、数据库更新操作、数据库删除操作、执行事务、错误处理的用法。
0 0
+关注
bisal
Oracle ACE,腾讯云TVP,墨天轮MVP,Oracle 10g/11g OCP,11g OCM,Exin DevOps Master,OCMU成员,Oracle YEP成员,微信公众号:bisal的个人杂货铺
文章
问答
文章排行榜
最热
最新
相关电子书
更多
让 MySQL 原生分布式触手可及
立即下载
好的 MySQL 兼容可以做到什么程度
立即下载
云数据库RDS MySQL从入门到高阶
立即下载