1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
|
#!/usr/local/bin/perl -w
# author: Al Tobey <albert.tobey@priority-health.com>
# what: process perfdata from Nagios and put it into RRD files
# license: GPL - http://www.fsf.org/licenses/gpl.txt
#
# Todo:
# * more documentation (POD) & comments
# * clean up a bit, make it more configurable - possibly a config file
use strict;
use lib qw( /opt/nagios/libexec );
use utils qw( %ERRORS );
use vars qw( $debug_file %data $debug $rrd_base $process_func $rrd_type );
use RRDs;
$debug_file = undef; #"/var/opt/nagios/perfdata.out";
$rrd_base = '/var/opt/nagios/rrds';
$process_func = \&process_multi;
$rrd_type = 'GAUGE';
$data{hostname} = shift(@ARGV);
$data{metric} = shift(@ARGV);
$data{timestamp} = shift(@ARGV);
$data{perfdata} = join( " ", @ARGV ); $data{perfdata} =~ s/\s+/ /g;
# make sure there's data to work with
exit $ERRORS{OK} if ( !defined($data{hostname}) || !defined($data{metric})
|| !defined($data{timestamp}) || !defined($data{perfdata})
|| $data{perfdata} eq ' ' || $data{perfdata} eq '' );
if ( defined($debug_file) ) {
open( LOGFILE, ">>$debug_file" );
print LOGFILE "$data{hostname}\t$data{metric}\t$data{timestamp}\t$data{perfdata}\n\n";
}
# make sure host directory exists
if ( !-d "$rrd_base/$data{hostname}" ) {
mkdir( "$rrd_base/$data{hostname}" )
|| warn "could not create host directory $rrd_base/$data{hostname}: $!";
}
our $rrd_dir = $rrd_base .'/'. $data{hostname};
# --------------------------------------------------------------------------- #
# do some setup based on the name of the metric
# host data
if ( $data{metric} eq "HOSTCHECK" ) {
$rrd_dir .= '/hostperf';
}
# processing disk information
elsif ( $data{metric} =~ /_DISK$/ ) {
$rrd_dir .= '/disk';
}
# network interface information
elsif ( $data{metric} =~ /^IFACE_/ ) {
$rrd_dir .= '/interfaces';
$rrd_type = [ 'COUNTER', 'COUNTER' ];
}
# process performance statistics
elsif ( $data{metric} =~ /_PROC$/ ) {
$rrd_dir .= '/processes';
$process_func = \&process_single;
$rrd_type = [ 'COUNTER', 'GAUGE' ];
}
# a resonable guess
elsif ( $data{perfdata} =~ /=/ ) {
$process_func = \&process_single;
}
# everything else
else {
$rrd_dir .= '/other';
}
# --------------------------------------------------------------------------- #
# call the proper processing function set up above (functions defined below)
our @processed = ( $process_func->() );
# --------------------------------------------------------------------------- #
if ( !-d $rrd_dir ) {
mkdir( $rrd_dir ) || warn "could not mkdir( $rrd_dir ): $!";
}
foreach my $datum ( @processed ) {
if ( defined($debug_file) ) {
print LOGFILE $datum->{rrd_name}, " = ", join('--',@{$datum->{data}}), "\n"
}
my $rrdfile = $rrd_dir.'/'.$datum->{rrd_name};
# create the RRD file if it doesn't already exist
if ( !-e $rrdfile ) {
# create a non-useful datasource title for each "part"
RRDs::create( $rrdfile, "-b", $data{timestamp}, "-s", 300, $process_func->($datum, 1),
"RRA:AVERAGE:0.5:1:600",
"RRA:MAX:0.5:1:600",
"RRA:AVERAGE:0.5:6:600",
"RRA:MAX:0.5:6:600",
"RRA:AVERAGE:0.5:24:600",
"RRA:MAX:0.5:24:600",
"RRA:AVERAGE:0.5:288:600",
"RRA:MAX:0.5:288:600"
);
if ( my $ERROR = RRDs::error ) { print "ERROR: $ERROR\n"; exit $ERRORS{UNKNOWN}; }
}
else {
# create a template to make sure data goes into the RRD as planned
if ( defined($debug_file) ) {
print LOGFILE "updating $rrdfile with data:\n\t",
join(':', $data{timestamp}, @{$datum->{data}}), "\n";
}
# update the RRD file
RRDs::update( $rrdfile, '-t', $process_func->($datum),
join(':', $data{timestamp}, @{$datum->{data}}) );
if ( my $ERROR = RRDs::error ) { print "ERROR: $ERROR\n"; exit $ERRORS{UNKNOWN}; }
}
}
# --------------------------------------------------------------------------- #
if ( defined($debug_file) ) {
print LOGFILE "-------------------------------------------------------------------------------\n";
close( LOGFILE );
}
exit $ERRORS{OK};
# /opt=value,value,value:/=value,value,value - into multiple rrd's
sub process_multi {
my( $datum, $create ) = @_;
# return a string for creating new RRDs
if ( defined($create) && $create == 1 ) {
my @DS = ();
for ( my $i=0; $i<scalar(@{$datum->{data}}); $i++ ) {
# allow the RRD type to be set in the switch/if above
my $tmp_rrd_type = $rrd_type;
if ( ref($rrd_type) eq 'ARRAY' ) { $tmp_rrd_type = $rrd_type->[$i] }
# put the new datasource into the list
push( @DS, "DS:$data{metric}$i:GAUGE:86400:U:U" );
}
return @DS;
}
# return a template for updating an RRD
elsif ( defined($datum) && !defined($create) ) {
my @template = ();
for ( my $i=0; $i<scalar(@{$datum->{data}}); $i++ ) {
push( @template, $data{metric}.$i );
}
return join( ':', @template );
}
# break the data up into parts for processing (updates and creates)
else {
my @processed = ();
foreach my $part ( split(/:/, $data{perfdata}) ) { # break the line into parts
my @parts = split( /,/, $part ); # break the part into parts
my $rrd_name = $parts[0]; # figure out a good name for the RRD
if ( $parts[0] =~ /^\// ) { # handle /'s in disk names
$rrd_name = $parts[0];
$rrd_name =~ s#/#_#g; $rrd_name =~ s/^_//; $rrd_name =~ s/_$//;
if ( $parts[0] eq '/' ) { $rrd_name = 'root' };
}
# store our munged data in an array of hashes
push( @processed, { rrd_name => $rrd_name, name => shift(@parts), data => [ @parts ] } );
}
return @processed;
}
}
# name=value:name=value - into one rrd
sub process_single {
my( $datum, $create ) = @_;
my( @names, @values ) = ();
foreach my $part ( split(/:/, $data{perfdata}) ) {
my( $name, $value ) = split( /=/, $part );
push( @names, $name );
push( @values, $value );
}
if ( defined($create) && $create == 1 ) {
my @DS = ();
for( my $i=0; $i<scalar(@names); $i++ ) {
my $tmp_rrd_type = $rrd_type;
if ( ref($rrd_type) eq 'ARRAY' ) { $tmp_rrd_type = $rrd_type->[$i] }
push( @DS, 'DS:'.$names[$i].":$tmp_rrd_type:86400:U:U" );
}
return @DS;
}
elsif ( defined($datum) && !defined($create) ) {
return join( ':', @names );
}
else {
return( {rrd_name=>lc($data{metric}), name=>$data{metric}, data=>[@values]} );
}
}
|