MySQL_qps

#!/usr/bin/env python
#_*_coding:utf8 _*_
import MySQLdb
import datetime
#qps
#!/usr/bin/env python
import MySQLdb
import time
from influxdb import InfluxDBClient
def getInfluxdb():
client=InfluxDBClient(host='192.168.15.104', port=8086, username='admin', password='root123', database='mysql15104')
return client
def get_cur():
conn=MySQLdb.connect(host="192.168.30.103",user="dlan",passwd="root123",port=3307,db="test",charset='utf8')
conn.select_db("test")
cur=conn.cursor()
return cur

def get_mysql_status(cursor):
data=cursor.execute('show global status;');
data_list=cursor.fetchall()
data_dict={}
for item in data_list:
data_dict[item[0]] = item[1]
return data_dict

def getQPS(cursor):
first_status=get_mysql_status(cursor)
time.sleep(1)
second_status=get_mysql_status(cursor)
qps=int(second_status['Com_select'])-int(first_status['Com_select'])

return qps

if __name__=='__main__':
while True:
cur=get_cur()
aa=getQPS(cur)
print aa
date=int(time.time())
json_body = [
{
"measurement":'wangyuan',
"tags":{
"host": "mycat",
"time":date
},
"fields":{
"qps":aa
}
}
]
print json_body