2
0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
contrib-munin/plugins/postgresql/slony_

105 lines
2.8 KiB
Perl
Executable File

#!/usr/bin/perl
# -*- perl -*-
# Jean-Samuel Reynaud <js.reynaud@free.fr>
# Based on postgres_locks
#
# Wildcard-plugin to monitor slony latency. To monitor a
# slony cluster, link slony_<cluster_schema> to this file. E.g.
#
# ln -s /usr/share/munin/node/plugins-auto/slony_ /etc/munin/node.d/slony__my_cluster
#
# ...will monitor my_cluster's slony cluster
#
# Show slony latency
#
# Parameters:
#
# config
# autoconf
#
#
#
# Configuration variables:
#
# PGHOST - Database server to use. Defaults to using ident
# authentication with the local server.
# PGPORT - Port to connect to. Defaults to '5432'.
# PGDATABASE - Database to connect to. Defaults to 'template1'.
# PGUSER - User to connect as, if necessary.
# PGPASSWORD - Corresponding password to use, if necessary.
#
# (See libpq documentation for more.)
# Note that PGDATABASE will default to 'template1' in this plugin, and
# without PGHOST it will try ident authentication with the local server,
# as the user that the plugin is running as.
#
# Configuration example:
#
# # Use local server, ident authentication with the 'postgres' user.
# [slony_*]
# user postgres
#
# # Use local server, TCP authentication with a username and password.
# [slony_*]
# env.PGHOST localhost
# env.PGUSER someuser
# env.PGDATABASE somedb
# env.PGPASSWORD somepassword
#
# Magic markers
#%# family=auto
#%# capabilities=
use strict;
use warnings;
use DBI;
my $cluster = $0;
$cluster =~ s/^.*slony_([\w\d\._\-]*)$/$1/;
# Default to template1 database.
$ENV{'PGDATABASE'} ||= 'template1';
my $dbh = DBI->connect ('dbi:Pg:', '', '', {RaiseError =>1})
|| die "Unable to access database.\nError returned was: ". $DBI::errstr;
if ($ARGV[0] && $ARGV[0] eq "config") {
print <<EOF;
graph_title Slony latency
graph_args --base 1000
graph_vlabel Latency in seconds
graph_category db
graph_info Shows Slony latency
EOF
my $sql="select no_id,no_comment,pa_conninfo from $cluster.sl_node join $cluster.sl_path on (pa_server=no_id) where pa_client= $cluster.getlocalnodeid('$cluster'::name);";
my $sth = $dbh->prepare ($sql);
$sth->execute ();
my $locks = 0;
my $exlocks = 0;
while (my ($no_id,$comment, $conninfo) = $sth->fetchrow ()) {
$conninfo =~ s/.*host=([\w\d\._\-]*)\s.*/$1/;
$no_id = sprintf("slave_%u",$no_id);
print<<EOF
$no_id.label $conninfo
$no_id.info $comment
$no_id.type GAUGE
$no_id.warning 60
$no_id.critical 1800
$no_id.min 0
EOF
}
} else {
my $sql="select st_received,st_lag_num_events,EXTRACT(EPOCH FROM st_lag_time)::integer from $cluster.sl_status;";
my $sth = $dbh->prepare ($sql);
$sth->execute ();
my $locks = 0;
my $exlocks = 0;
while (my ($no_id,$nb_event, $lag) = $sth->fetchrow ()) {
$no_id = sprintf("slave_%u",$no_id);
print "$no_id.value $lag\n"
}
}