munin/nominatim_query_speed

   1 #!/usr/bin/perl -w
   2 # Plugin to monitor response time of search queries.
   3 #
   4 # Based on a plugin by Dalibo <cedric.villemain@dalibo.com> 2007
   5 # Based on a plugin (postgres_block_read_) from Björn Ruberg <bjorn@linpro.no>
   6 #
   7 # Licenced under GPL v2.
   8 #
   9 # Usage:
  10 #
  11 #       If required, give username, password and/or Postgresql server
  12 #       host through environment variables. See man page of psql for
  13 #       more info.
  14 #
  15 # Parameters:
  16 #
  17 #       config   (required)
  18 #
  19 # Magic markers
  20 #%# family=auto
  21 #%# capabilities=autoconf
  22
  23 use strict;
  24 use DBI;
  25 use vars qw ( $debug $configure  );
  26 use constant _PGMINI => 70400;
  27
  28 my $dbhost = $ENV{'PGHOST'} || '';
  29 my $dbname = $ENV{'PGDATABASE'} || 'nominatim';
  30 my $dbuser = $ENV{'PGUSER'} || 'postgres';
  31 my $dbport = $ENV{'PGPORT'} || '5432';
  32
  33 my $dsn = "DBI:Pg:dbname=$dbname";
  34 $dsn   .=";host=$dbhost;port=$dbport" if $dbhost;
  35 my $pg_server_version;
  36
  37 if (exists $ARGV[0]) {
  38   if ($ARGV[0] eq 'autoconf') {
  39     # Check for DBD::Pg
  40     if (! eval "require DBD::Pg;") {
  41       print "no (DBD::Pg not found)";
  42       exit 1;
  43     }
  44     my $dbh = DBI->connect ($dsn,
  45                             $dbuser,
  46                             '',
  47                             {RaiseError =>1});
  48     if ($dbh) {
  49       $pg_server_version = $dbh->{'pg_server_version'};
  50       if ($pg_server_version < (_PGMINI)) {
  51         $pg_server_version =~ /(\d)(\d){2,2}(\d){2,2}/;
  52         print "PostgreSQL Server version " . (_PGMINI) . " or above is needed. Current is $1.$2.$3 \n";
  53                                 exit 1;
  54       }
  55       print "yes\n";
  56       exit 0;
  57     } else {
  58       print "no Unable to access Database $dbname on host $dbhost as user $dbuser.\nError returned was: ". $DBI::errstr;
  59       exit 1;
  60     }
  61   } elsif ($ARGV[0] eq 'debug') {
  62     # Set debug flag
  63     $debug = 1;
  64   } elsif ($ARGV[0] eq 'config') {
  65     # Set config flag
  66     $configure = 1;
  67   }
  68 }
  69
  70 print "# $dsn\n" if $debug;
  71 my $dbh = DBI->connect ($dsn,
  72                         $dbuser,
  73                         '',
  74                         {RaiseError =>1});
  75
  76 die ("no Unable to access Database $dbname on host $dbhost as user $dbuser.\nError returned was: ". $DBI::errstr."\n") unless($dbh);
  77 $pg_server_version = $dbh->{'pg_server_version'};
  78
  79 if ($configure) {
  80   print "graph_title Total Nominatim response time\n";
  81   print "graph_vlabel Time to response\n";
  82   print "graph_category Nominatim \n";
  83   print "graph_period minute\n";
  84   print "graph_args --base 1000\n";
  85
  86   print "avg.label Average time to response\n";
  87   print "avg.draw LINE\n";
  88   print "avg.type GAUGE\n";
  89   print "avg.min 0\n";
  90   print "avg.info Moving 5 minute average time to perform search\n";
  91   print "avg.label Average time to response\n";
  92
  93   print "min.label Fastest time to response\n";
  94   print "min.draw LINE\n";
  95   print "min.type GAUGE\n";
  96   print "min.min 0\n";
  97   print "min.info Fastest query in last 5 minutes\n";
  98
  99   print "max.label Slowest time to response\n";
 100   print "max.draw LINE\n";
 101   print "max.type GAUGE\n";
 102   print "max.min 0\n";
 103   print "max.info Slowest query in last 5 minutes\n";
 104
 105 } else {
 106
 107   my $sql = "select TO_CHAR(avg(endtime-starttime),'SS.MS'),TO_CHAR(min(endtime-starttime),'SS.MS'),TO_CHAR(max(endtime-starttime),'SS.MS') from new_query_log where starttime > 'now'::timestamp - '5 minutes'::interval";
 108   print "# $sql\n" if $debug;
 109   my $sth = $dbh->prepare($sql);
 110   $sth->execute();
 111   printf ("# Rows: %d\n",  $sth->rows) if $debug;
 112   if ($sth->rows > 0) {
 113     my ($avg, $min, $max) = $sth->fetchrow_array();
 114     print "avg.value $avg\n";
 115     print "min.value $min\n";
 116     print "max.value $max\n";
 117   }
 118 }
 119
 120 exit 0;
 121