Das Asterisk Buch

Leider kann Asterisk derzeit das Queue-Log noch nicht direkt in eine SQL-Datenbank-Tabelle schreiben. Dass die Daten in einer SQL-Datenbank liegen, ist aber für alle bekannten Statistik-Tools eine Grundvoraussetzung. Zu diesem Zweck existieren verschiedene Skripte^[90] (meist in Perl) bzw. werden mit den Tools mitgeliefert. Sie alle gehen den Weg, der im unten angefügten Skript beschrieben ist, die Datei queue_log durch eine Named-Pipe (FIFO) zu ersetzen. Das Skript öffnet die FIFO zum Lesen, und sobald Asterisk eine Log-Meldung hineinschreibt, wird diese in die Datenbank eingetragen.

	Warnung
	Diese Methode wird vermutlich in 99 % aller Fälle problemlos funktionieren. Allerdings besteht die Gefahr, dass das Skript, falls es aus irgendwelchen Gründen nicht vor Asterisk gestartet sein sollte oder vorzeitig beendet wird, nicht mehr aus der Named-Pipe liest und Asterisk beim Versuch, zu schreiben, ein SIGPIPE-Signal erhält, was Asterisk zum Absturz bringen würde!

Da aber ohne Unterstützung durch Asterisk keine wirkliche Alternative besteht, soll hier trotz der Gefahr, die theoretisch besteht, ein Perl-Skript von William Lloyd den Ansatz beschreiben^[91]:

#!/usr/bin/perl -w
#
# wlloyd at slap.net

# The asterisk version indpendant way to get queue stats into Mysql,  
Postgres
# or whatever is supported by Perl DBI

# It's all about named pipes

# to setup this software
# stop asterisk
# rm /var/log/asterisk/queue_log
# mkfifo /var/log/asterisk/queue_log

# make sure permissions are setup
# chmod 777 /var/log/asterisk/queue_log

# run this program as root or under another user as you see fit.
# should start BEFORE asterisk.  Add to /etc/rc.d/rc.local or whatever

# restart asterisk

# requires a DB table like the following..
# CREATE TABLE csr_queue (
#  qname varchar(30) default NULL,
#  agent varchar(30) default NULL,
#  action text,
#  info1 text,
#  info2 text,
#  info3 text,
#  timestamp int(11) NOT NULL default '0',
#  id tinytext NOT NULL
#) TYPE=MyISAM;

use DBI;
use IO::File;

my $opt_debug = 0;

# if you want postgres change this to "Pg"
my $db_type = "mysql";
my $db_host = "127.0.0.1";
my $db_user_name = 'username';
my $db_password = 'password';
my $db_database = 'asteriskstat';

my $dbh = DBI->connect("DBI:$db_type:dbname=$db_database;host= 
$db_host;", $db_user_name, $db_password);

open(FIFO, "< /var/log/asterisk/queue_log")        or die "Can't open  
queue_log : $!\n";

while (1) {

     $message = <FIFO>;
     next unless defined $message;   # interrupted or nothing logged
     chomp $message;

     # remove chars that will cause DB problems
     $message =~ s/\"\'//g;

     @data = split(/\|/,$message);

     # these messages are almost useless for my purposes
     next if ($data[4] eq "QUEUESTART" );
     next if ($data[4] eq "CONFIGRELOAD" );

     if (!defined($data[5])) {
       $data[5] = '';
     }
     if (!defined($data[6])) {
       $data[6] = '';
     }
     if (!defined($data[7])) {
       $data[7] = '';
     }

     my $sql = "INSERT INTO csr_queue (timestamp, id, qname, agent,  
action, info1, info2, info3) VALUES ('$data[0]', '$data[1]', '$data 
[2]', '$data[3]', '$data[4]', '$data[5]', '$data[6]', '$data[7]')";

     print "$sql \n\n" if ($opt_debug);

     $dbh->do($sql);

# if you want an actual logfile you might want to uncomment this
#        if ( open(LOG, ">> /var/log/asterisk/queue_log_real") ) {
#            print LOG "$message\n";
#            close(LOG);
#        } else {
#            warn "Couldn't log to /var/log/asterisk_queue_log: $!\n";
#        }
#
}

$dbh->disconnect();

exit 0;

Bei QueueMetrics (kostenlose Demo-Version) wird ebenfalls ein Perl-Skript namens queueLoader.pl mitgeliefert (siehe aber die Warnung oben!).

Alternativ dazu kann man die Datei auch regelmäßig (z. B. minütlich per Cron-Job) rotieren und in die Datenbank einlesen. ^[92]