Munin contributed plugins

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# vim: set fileencoding=utf-8

#

# Munin plugin for Percona XtraDB Cluster. Monitors values of these cluster replication variables:

# percona_queues: wsrep_local_recv_queue, wsrep_local_send_queue

# percona_flow: wsrep_flow_control_sent, wsrep_flow_control_recv

# percona_transactions: wsrep_replicated, wsrep_received

# percona_transactions_bytes: wsrep_replicated_bytes, wsrep_received_bytes

# percona_replication: wsrep_local_cert_failures, wsrep_local_bf_aborts

#

# 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 XtraDB Cluster-Server:

#

#     [percona]

#     env.user root

#     env.password vErYsEcReT

#

#  #%# capabilities=autoconf

#  #%# family=contrib

import os

import sys

from warnings import filterwarnings

import MySQLdb

import MySQLdb.cursors

filterwarnings('ignore', category=MySQLdb.Warning)

program_name = 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"] is not None:

    server = os.environ["host"]

else:

    server = "localhost"

# Mysql port

if "port" in os.environ and os.environ["port"] is not 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"] is not None:

    login = os.environ["user"]

else:

    login = ""

# Mysql password

if "password" in os.environ and os.environ["password"] is not None:

    passw = os.environ["password"]

else:

    passw = ""

# Mysql connection handler

conn = None

label = variables[program_name]['label']

vlabel = variables[program_name]['vlabel']

fields = ["'{0}'".format(x) for x in variables[program_name]['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 as 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 db")

    print()

    try:

        cursor.execute(query)

        results = cursor.fetchall()

        for result in results:

            print("%s_size.label %s" % (result[0], result[0]))

    except MySQLdb.Error as 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 as e:

        print("Error %d: %s" % (e.args[0], e.args[1]))

if conn:

    conn.close()