1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
### Author: <lefred@inuits.be>
global mysql_user
mysql_user = os.getenv('DSTAT_MYSQL_USER') or os.getenv('USER')
global mysql_pwd
mysql_pwd = os.getenv('DSTAT_MYSQL_PWD')
global mysql_host
mysql_host = os.getenv('DSTAT_MYSQL_HOST')
global mysql_port
mysql_port = os.getenv('DSTAT_MYSQL_PORT')
global mysql_socket
mysql_socket = os.getenv('DSTAT_MYSQL_SOCKET')
class dstat_plugin(dstat):
"""
Plugin for MySQL 5 commands.
"""
def __init__(self):
self.name = 'mysql5 cmds'
self.nick = ('sel', 'ins','upd','del')
self.vars = ('Com_select', 'Com_insert','Com_update','Com_delete')
self.type = 'd'
self.width = 5
self.scale = 1
def check(self):
global MySQLdb
import MySQLdb
try:
args = {}
if mysql_user:
args['user'] = mysql_user
if mysql_pwd:
args['passwd'] = mysql_pwd
if mysql_host:
args['host'] = mysql_host
if mysql_port:
args['port'] = mysql_port
if mysql_socket:
args['unix_socket'] = mysql_socket
self.db = MySQLdb.connect(**args)
except Exception as e:
raise Exception('Cannot interface with MySQL server: %s' % e)
def extract(self):
try:
c = self.db.cursor()
for name in self.vars:
c.execute("""show global status like '%s';""" % name)
line = c.fetchone()
if line[0] in self.vars:
if line[0] + 'raw' in self.set2:
self.set2[line[0]] = int(line[1]) - self.set2[line[0] + 'raw']
self.set2[line[0] + 'raw'] = int(line[1])
for name in self.vars:
self.val[name] = self.set2[name] * 1.0 / elapsed
if step == op.delay:
self.set1.update(self.set2)
except Exception as e:
for name in self.vars:
self.val[name] = -1
|
