Merge pull request #461 from muffl0n/percona_plugin

Create plugin percona_

plugins/percona/percona_

@@ -0,0 +1,151 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+# vim: set fileencoding=utf-8
+#
+# Munin plugin for percona
+#
+# created by Sven Schliesing
+# borrowed code from mysql_aggregate_ by Igor Borodikhin
+#
+# License : GPLv3
+#
+# parsed environment variables:
+# host: hostname or ip-address of Mysql server (default - localhost)
+# port: port number of Mysql server (default - 3306)
+# user: username to access Mysql server (default - empty)
+# password: password of Mysql user (default - empty)
+#
+# ## Requirements
+# This plugin requires pythons MySQLdb module which can be installed via easy_install.
+#
+# ## Installation
+# Copy file to directory /usr/share/munin/plugins/ and create symbolic links for each type you wish to monitor:
+# 	percona_flow
+# 	percona_queues
+# 	percona_replication
+# 	percona_transactions
+# 	percona_transactions_bytes
+#
+# Minimal config for monitoring local Percona-Server:
+#
+#     [percona]
+#     env.user root
+#     env.password vErYsEcReT
+#
+#%# capabilities=autoconf
+#%# family=contrib
+
+from warnings import filterwarnings
+import os, sys, MySQLdb, MySQLdb.cursors
+filterwarnings('ignore', category = MySQLdb.Warning)
+
+progName = os.path.basename(__file__)
+
+variables = {
+  'percona_queues': {
+    'label': 'Queue sizes',
+    'vlabel': 'size',
+    'fields': ['wsrep_local_recv_queue', 'wsrep_local_send_queue']
+  },
+  'percona_flow': {
+    'label': 'Flow control',
+    'vlabel': '',
+    'fields': ['wsrep_flow_control_sent', 'wsrep_flow_control_recv']
+  },
+  'percona_transactions': {
+    'label': 'Transactions in and out',
+    'vlabel': 'transactions',
+    'fields': ['wsrep_replicated', 'wsrep_received']
+  },
+  'percona_transactions_bytes': {
+    'label': 'Transactions in and out in bytes',
+    'vlabel': 'bytes',
+    'fields': ['wsrep_replicated_bytes', 'wsrep_received_bytes']
+  },
+  'percona_replication': {
+    'label': 'Replication conflicts',
+    'vlabel': 'conflicts',
+    'fields': ['wsrep_local_cert_failures', 'wsrep_local_bf_aborts'],
+  }
+}
+
+# Parse environment variables
+# Mysql host
+if "host" in os.environ and os.environ["host"] != None:
+    server = os.environ["host"]
+else:
+    server =  "localhost"
+
+# Mysql port
+if "port" in os.environ and os.environ["port"] != None:
+    try:
+        port = int(os.environ["port"])
+    except ValueError:
+        port = 3306
+else:
+    port = 3306
+
+# Mysql username
+if "user" in os.environ and os.environ["user"] != None:
+    login = os.environ["user"]
+else:
+    login = ""
+
+# Mysql password
+if "password" in os.environ and os.environ["password"] != None:
+    passw = os.environ["password"]
+else:
+    passw = ""
+
+# Mysql connection handler
+conn = None
+
+label = variables[progName]['label']
+vlabel = variables[progName]['vlabel']
+fields = ['\'{0}\''.format(x) for x in variables[progName]['fields']]  
+
+query = "show status where Variable_name in (%s)" % ', '.join(fields)
+
+# Connect to mysql
+try:
+    conn = MySQLdb.connect(host=server, user=login, passwd=passw)
+    cursor = conn.cursor()
+except MySQLdb.Error, e:
+    print "Error %d: %s" % (e.args[0], e.args[1])
+    sys.exit(1)
+
+
+values = {}
+
+if len(sys.argv) == 2 and sys.argv[1] == "autoconf":
+    print "yes"
+elif len(sys.argv) == 2 and sys.argv[1] == "config":
+
+    print "graph_title %s" % label
+    print "graph_vlabel %s" % vlabel
+    print "graph_category percona"
+    print ""
+
+    try:
+        cursor.execute(query)
+        results = cursor.fetchall()
+
+        for result in results:
+        	print "%s_size.label %s" % (result[0], result[0])
+
+    except MySQLdb.Error, e:
+        print "Error %d: %s" % (e.args[0], e.args[1])
+
+else:
+    try:
+        cursor.execute(query)
+        results = cursor.fetchall()
+
+        for result in results:
+        	print "%s_size.value %s" % (result[0], result[1])
+
+    except MySQLdb.Error, e:
+        print "Error %d: %s" % (e.args[0], e.args[1])
+
+if conn:
+    conn.close()