Robot/contrib-munin
2
0
Fork 0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
Code Issues Releases Wiki Activity

Added simple graph mode for queries without GROUP BY statement

Browse Source
This commit is contained in:
iborodikhin 2012-09-12 10:17:19 +06:00
parent c561076a32
commit 42a11debca
1 changed files with 55 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
plugins/mysql/mysql_aggregate_
View File

@ -14,8 +14,8 @@
# user: username to access Mysql server (default - empty) # user: username to access Mysql server (default - empty)
# password: password of Mysql user (default - empty) # password: password of Mysql user (default - empty)
# database: Mysql database name (default - empty) # database: Mysql database name (default - empty)
# table: Mysql table name (no defaul, raises exception) # table: Mysql table name (no default, raises exception)
# field: field name, used in GROUP BY statement (no default, raises exception) # field: field name, used in GROUP BY statement (default - empty, no group by)
# where: optional where condition (without "where", default - empty) # where: optional where condition (without "where", default - empty)
# #
# This plugin shows graphs of Mysql COUNT(*) results. # This plugin shows graphs of Mysql COUNT(*) results.
@ -88,9 +88,11 @@ else:
raise Exception("You should provide 'env.table' in configuration file") raise Exception("You should provide 'env.table' in configuration file")
# Mysql group by field # Mysql group by field
if "field" in os.environ and os.environ["field"] != None: if "field" in os.environ and os.environ["field"] != None:
field = os.environ["field"] groupBy = "GROUP BY %s" % os.environ["field"]
field = "%s, " % os.environ["field"]
else: else:
raise Exception("You should provide 'env.field' in configuration file") groupBy = ""
field = ""
# Mysql where condition # Mysql where condition
if "where" in os.environ and os.environ["where"] != None: if "where" in os.environ and os.environ["where"] != None:
@ -102,9 +104,9 @@ else:
conn = None conn = None
# Query to get field values # Query to get field values
valuesQuery = "SELECT DISTINCT %s FROM %s %s" % (field, table, where) valuesQuery = "SELECT DISTINCT %s 1 FROM %s %s" % (field, table, where)
# Query to get graph data # Query to get graph data
aggregateQuery = "SELECT %s, COUNT(*) FROM %s %s GROUP BY %s" % (field, table, where, field) aggregateQuery = "SELECT %sCOUNT(*) FROM %s %s %s" % (field, table, where, groupBy)
# Connect to mysql # Connect to mysql
try: try:
@ -115,50 +117,67 @@ except MySQLdb.Error, e:
sys.exit(1) sys.exit(1)
# init values tuple # init values tuple
values = {} if field != "":
cursor.execute(valuesQuery) values = {}
results = cursor.fetchall() cursor.execute(valuesQuery)
for result in results: results = cursor.fetchall()
values[result[0]] = 0 for result in results:
values[result[0]] = 0
if len(sys.argv) == 2 and sys.argv[1] == "autoconf": if len(sys.argv) == 2 and sys.argv[1] == "autoconf":
print "yes" print "yes"
elif len(sys.argv) == 2 and sys.argv[1] == "config": elif len(sys.argv) == 2 and sys.argv[1] == "config":
print "multigraph mysql_aggregate_%s" % table if field == "":
print "graph_title Aggregate - %s" % table print "graph mysql_aggregate_%s" % table
print "graph_vlabel count(*)" print "graph_title Aggregate - %s" % table
print "graph_category mysql"
print ""
for key in values.keys():
print "%s_count.label %s" % (key.replace(".", "_"), key.replace(".", "_"))
for key in values.keys():
print ""
print "multigraph mysql_aggregate_%s.%s" % (table, key.replace(".", "_"))
print "graph_title Agregate - %s, value %s" % (table, key.replace(".", "_"))
print "graph_vlabel count(*)" print "graph_vlabel count(*)"
print "graph_category mysql" print "graph_category mysql"
print "" print ""
print "%s_count.label %s" % (key.replace(".", "_"), key) print "values_count.label count"
else:
print "multigraph mysql_aggregate_%s" % table
print "graph_title Aggregate - %s" % table
print "graph_vlabel count(*)"
print "graph_category mysql"
print "" print ""
else:
try:
cursor.execute(aggregateQuery)
results = cursor.fetchall()
for result in results:
values[result[0]] = result[1]
print "multigraph mysql_aggregate_%s" % table
for key in values.keys(): for key in values.keys():
print "%s_count.value %s" % (key.replace(".", "_"), values[key]) print "%s_count.label %s" % (key.replace(".", "_"), key.replace(".", "_"))
for key in values.keys(): for key in values.keys():
print "" print ""
print "multigraph mysql_aggregate_%s.%s" % (table, key.replace(".", "_")) print "multigraph mysql_aggregate_%s.%s" % (table, key.replace(".", "_"))
print "%s_count.value %s" % (key.replace(".", "_"), values[key]) print "graph_title Agregate - %s, value %s" % (table, key.replace(".", "_"))
print "graph_vlabel count(*)"
print "graph_category mysql"
print ""
print "%s_count.label %s" % (key.replace(".", "_"), key)
print ""
else:
try:
cursor.execute(aggregateQuery)
if field == "":
result = cursor.fetchone()
count = 0
if result[0]:
count = count + result[0]
print "values_count.value %s" % count
else:
results = cursor.fetchall()
for result in results:
values[result[0]] = result[1]
print "multigraph mysql_aggregate_%s" % table
for key in values.keys():
print "%s_count.value %s" % (key.replace(".", "_"), values[key])
for key in values.keys():
print ""
print "multigraph mysql_aggregate_%s.%s" % (table, key.replace(".", "_"))
print "%s_count.value %s" % (key.replace(".", "_"), values[key])
except MySQLdb.Error, e: except MySQLdb.Error, e:
print "Error %d: %s" % (e.args[0], e.args[1]) print "Error %d: %s" % (e.args[0], e.args[1])