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

Merge pull request #330 from sipb/mysql_aggregate-max

Browse source 
mysql_aggregate_: allow graphing only max/min value
This commit is contained in:
Kenyon Ralph 2013-07-07 18:22:18 -07:00
commit 0d360f18da
1 changed files with 32 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
plugins/mysql/mysql_aggregate_
View file

@ -17,6 +17,7 @@
# table: Mysql table name (no default, raises exception) # table: Mysql table name (no default, raises exception)
# field: field name, used in GROUP BY statement (default - empty, no group by) # 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)
# only: optional; "max" or "min" to indicate that only the largest or smallest value should be graphed
# #
# This plugin shows graphs of Mysql COUNT(*) results. # This plugin shows graphs of Mysql COUNT(*) results.
# #
@ -96,6 +97,20 @@ else:
groupBy = "" groupBy = ""
field = "" field = ""
if "only" in os.environ and os.environ["only"] != None:
if not field:
raise Exception("You should provide 'env.field' in configuration file")
only = os.environ["only"]
if only == "max":
dir = "DESC"
elif only == "min":
dir = "ASC"
else:
raise Exception("env.only should be 'max' or 'min'; found %s") % (only, )
order_by = "ORDER BY COUNT(*) %s LIMIT 1" % (dir, )
else:
order_by = ""
# 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:
where = "WHERE %s" % os.environ["where"] where = "WHERE %s" % os.environ["where"]
@ -105,10 +120,10 @@ else:
# Mysql connection handler # Mysql connection handler
conn = None conn = None
# Query to get field values # Query to get field values (used only when graphing several values)
valuesQuery = "SELECT DISTINCT %s 1 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 %sCOUNT(*) FROM %s %s %s" % (field, table, where, groupBy) aggregateQuery = "SELECT %sCOUNT(*) FROM %s %s %s %s" % (field, table, where, groupBy, order_by)
# Connect to mysql # Connect to mysql
try: try:
@ -118,8 +133,10 @@ except MySQLdb.Error, e:
print "Error %d: %s" % (e.args[0], e.args[1]) print "Error %d: %s" % (e.args[0], e.args[1])
sys.exit(1) sys.exit(1)
single_value = field == "" or order_by != ""
# init values tuple # init values tuple
if field != "": if not single_value:
values = {} values = {}
cursor.execute(valuesQuery) cursor.execute(valuesQuery)
results = cursor.fetchall() results = cursor.fetchall()
@ -140,13 +157,16 @@ elif len(sys.argv) == 2 and sys.argv[1] == "config":
else: else:
vlabel = "count(*)" vlabel = "count(*)"
if field == "": if single_value:
print "graph mysql_aggregate_%s" % table print "graph mysql_aggregate_%s" % table
print "graph_title %s" % label print "graph_title %s" % label
print "graph_vlabel %s" % vlabel print "graph_vlabel %s" % vlabel
print "graph_category mysql" print "graph_category mysql"
print "" print ""
print "values_count.label count" if "only" in os.environ:
print "values_count.label %s" % (os.environ["only"], )
else:
print "values_count.label count"
else: else:
print "multigraph mysql_aggregate_%s" % table print "multigraph mysql_aggregate_%s" % table
print "graph_title %s" % label print "graph_title %s" % label
@ -171,11 +191,15 @@ else:
try: try:
cursor.execute(aggregateQuery) cursor.execute(aggregateQuery)
if field == "": if single_value:
result = cursor.fetchone() result = cursor.fetchone()
count = 0 count = 0
if result[0]: if field:
count = count + result[0] ind = 1
else:
ind = 0
if result[ind]:
count = count + result[ind]
print "values_count.value %s" % count print "values_count.value %s" % count
else: else:
results = cursor.fetchall() results = cursor.fetchall()