neuer versuch mit munin für immer1-5
[puppet_munin.git] / files / plugins / pg__connections
1 #!/usr/bin/perl -w
2 # Plugin for monitor postgres connections.
3 #
4 # Licenced under GPL v2.
5 #
6 # Usage:
7 #
8 #       Symlink into /etc/munin/plugins/ and add the monitored
9 #       database to the filename. e.g.:
10 #
11 #       ln -s /usr/share/munin/plugins/pg__connections \
12 #         /etc/munin/plugins/pg_<databasename>_connections
13 #       This should, however, be given through autoconf and suggest.
14 #
15 #       If required, give username, password and/or Postgresql server
16 #       host through environment variables.
17 #
18 #       You must also activate Postgresql statistics. See
19 #       http://www.postgresql.org/docs/7.4/interactive/monitoring-stats.html
20 #       for how to enable this. Specifically, the following lines must
21 #       exist in your postgresql.conf:
22 #
23 #           stats_start_collector = true
24 #           stats_block_level = true
25 #
26 #
27 # Parameters:
28 #
29 #       config   (required)
30 #
31 # Config variables:
32 #
33 #       dbhost     - Which database server to use. Defaults to
34 #                    'localhost'.
35 #       dbname     - Which database to use. Defaults to template1
36 #       dbuser     - A Postgresql user account with read permission to
37 #                    the given database. Defaults to
38 #                    'postgres'. Anyway, Munin must be told which user
39 #                    this plugin should be run as.
40 #       dbpass     - The corresponding password, if
41 #                    applicable. Default to undef. Remember that
42 #                    pg_hba.conf must be configured accordingly.
43 #
44 # Magic markers
45 #%# family=auto
46 #%# capabilities=autoconf
47
48 use strict;
49 use DBI;
50
51 my $dbhost = $ENV{'dbhost'} || '127.0.0.1';
52 my $dbname = $ENV{'dbname'} || 'template1';
53 my $dbuser = $ENV{'dbuser'} || 'postgres';
54 my $dbuserx = $ENV{'dbuserx'} || '';
55 my $dbport = $ENV{'dbport'} || '5432';
56 my $dbpass = $ENV{'dbpass'} || '';
57
58 # Check for DBD::Pg
59 if (! eval "require DBD::Pg;") {
60         print "requires DBD::Pg\n";
61      exit 1;
62 }
63
64 my $dsn = "DBI:Pg:dbname=$dbname;host=$dbhost;port=$dbport";
65 #print "$dsn\n";
66 my $dbh = DBI->connect ($dsn, $dbuser,
67                         $dbpass,
68                         {RaiseError =>1}) || die "";
69
70
71
72 if (exists $ARGV[0]) {
73     if ($ARGV[0] eq 'autoconf') {
74         # Check for DBD::Pg
75         if (! eval "require DBD::Pg;") {
76              print "no (DBD::Pg not found)";
77              exit 1;
78         }
79         if ($dbh) {
80             print "yes\n";
81             exit 0;
82         } else {
83             print "no Unable to access Database $dbname on host $dbhost as user $dbuser.\nError returned was: ". $DBI::errstr;
84             exit 1;
85         }
86     }
87
88     if ($ARGV[0] eq "config") {
89         my $sql_max = "SHOW max_connections;";
90         my $sth_max = $dbh->prepare($sql_max);
91         $sth_max->execute();
92         my ($max_connections) = $sth_max->fetchrow();
93         my $warning = int ($max_connections * 0.7);
94         my $critical = int ($max_connections * 0.8);
95         print "graph_title PostgresSQL active connections\n";
96         print "graph_args -l 0 --base 1000\n";
97         print "graph_vlabel Connections\n";
98         print "graph_category Postgresql\n";
99         print "graph_info Shows active Postgresql connections from $dbname\n";
100         
101
102         my $sql = "select datname, count(*) from pg_stat_activity group by datname";
103         my $sth = $dbh->prepare($sql);
104         $sth->execute();
105         my $setarea = "yes";
106         while ( my ($datname,$curr_conn) = $sth->fetchrow_array ) {
107                 print "$datname.label $datname active connections\n";
108                 print "$datname.info $datname active connections\n";
109                 print "$datname.type GAUGE\n";
110                 if ($setarea eq "yes") {
111                         print "$datname.draw AREA\n";
112                         $setarea="";
113                 } else {
114                         print "$datname.draw STACK\n";
115                 }
116         }
117
118         print "max_connections.label Max. connections\n";
119         print "max_connections.info Max. connections\n";
120         print "max_connections.type GAUGE\n";
121
122         print "warning $warning\n";
123         print "critical $critical\n";
124         exit 0;
125     }
126 }
127
128
129 # select datname, count(*) from pg_stat_activity group by datname
130 my $sql_max = "SHOW max_connections;";
131 my $sth_max = $dbh->prepare($sql_max);
132 $sth_max->execute();
133 my ($max_connections) = $sth_max->fetchrow();
134
135 #my $sql = "SELECT COUNT (*) FROM pg_stat_activity;";
136 my $sql = "select datname, count(*) from pg_stat_activity group by datname";
137 my $sth = $dbh->prepare($sql);
138 $sth->execute();
139 while ( my ($datname,$curr_conn) = $sth->fetchrow_array ) {
140         print "$datname.value $curr_conn\n";
141 }
142 print "max_connections.value $max_connections\n";