Robot/contrib-munin
2
0
Fork 0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
Code Issues Releases Wiki Activity
c6c9e5b41e
contrib-munin/tools/munin2snmp/munin2snmp

285 lines
8.4 KiB
Perl
Executable File
Raw Blame History

#!/usr/bin/perl
use warnings;
use strict;
use NetSNMP::OID;
use NetSNMP::ASN (':all');
use NetSNMP::agent (':all');
use IO::Socket;
use Getopt::Long;
use Pod::Usage;
my %cache = (); # Cache
my @cache_oids = (); # Keys, sorted
my $cache_updated = 0;
my $delimiter = ' = ';
my $conf = '/etc/munin2snmp.conf';
my %config;
my $pidfile = '/var/run/munin2snmp.pid';
my $usage = "Usage: $0 [options] \
Options:
--help : print help message\
--host [host] : munin-node host, default localhost\
--port [port] : munin-node port, default 4949\
--base_oid [OID] : base oid, default .1.3.6.1.4.1.123456.100.1.1\
Don't forget to update MUNIN-MIB OBJECT IDENTIFIER if you modify base_oid\
--plugins [load,cpu,..] : comma separated list of munin-node plugins, default cpu,load,df\
--pidfile [file path] : pidfile, default /var/run/munin2snmp.pid\
";
sub read_conf {
return if ( ! -e $conf );
open my $conf_fh,'<',$conf or die "Can't open the $conf, $!\n";
while (<$conf_fh>) {
chomp;
my ($param, $val) = split(/\s*=\s*/);
$config{"$param"} = $val;
}
}
# initialize
my %Munin;
if ( ! scalar @ARGV ) {
read_conf;
}
GetOptions (
"help" => sub{pod2usage($usage)},
"host=s" => \$config{munin_host},
"port=s" => \$config{munin_port},
"base_oid=s" => \$config{'base_oid'},
"plugins=s" => \$config{'munin_plugins'},
"pidfile=s" => \$pidfile,
);
$Munin{PORT} = $config{'munin_port'} || '4949';
$Munin{HOST} = $config{'munin_host'} || 'localhost';
my $oidbase = $config{'base_oid'} || '.1.3.6.1.4.1.123456.100.1.1';
# See munin plugins dir for more plugins
my @munin_plugins = qw (cpu load df);
@munin_plugins = split(',',$config{'munin_plugins'}) if ( $config{'munin_plugins'});
open my $pidfd,'>',$pidfile or die "Can't open $pidfile, $!\n";
print $pidfd $$;
close $pidfd;
# Update cache
sub update_stats {
return if time() - $cache_updated < 30;
%cache = ();
foreach my $plugin (@munin_plugins) {
$plugin =~ s/^.*\///;
my $DATA = munin_fetch($plugin);
foreach my $line (@$DATA) {
# Extract name and value
next if $line !~ m/^(.*)\s=\s(.*)$/xms;
my ($name,$value) = ($1,$2);
# Compute OID
my $oid = "$oidbase";
foreach my $char (split //, $name) {
$oid .= ".";
$oid .= ord($char);
}
# Put in the cache
$cache{$oid} = $value;
}
}
@cache_oids = sort { new NetSNMP::OID($a) <=> new NetSNMP::OID($b) } (keys %cache);
$cache_updated = time();
}
# Handle request
sub handle_stats {
my ($handler, $registration_info, $request_info, $requests) = @_;
update_stats; # Maybe we should do this in a thread...
for (my $request = $requests; $request; $request = $request->next()) {
$SNMP::use_numeric = 1;
my $oid = $request->getOID();
my $noid=SNMP::translateObj($oid);
if ($request_info->getMode() == MODE_GET) {
# For a GET request, we just check the cache
if (exists $cache{$noid}) {
$request->setValue(ASN_OCTET_STR, "$cache{$noid}");
}
}
elsif ($request_info->getMode() == MODE_GETNEXT) {
# For a GETNEXT, we need to find a best match. This is the
# first match strictly superior to the requested OID.
my $bestoid = undef;
foreach my $currentoid (@cache_oids) {
$currentoid = new NetSNMP::OID($currentoid);
next if $currentoid <= $oid;
$bestoid = $currentoid;
last;
}
if (defined $bestoid) {
$SNMP::use_numeric = 1;
my $noid=SNMP::translateObj($bestoid);
$request->setOID($bestoid);
$request->setValue(ASN_OCTET_STR, "$cache{$noid}");
}
}
}
}
my $agent = new NetSNMP::agent(
'Name' => "munin",
'AgentX' => 1);
# Register MIB
$agent->register("munin-stats", $oidbase,
\&handle_stats) or die "registration of handler failed!\n";
# Main loop
$SIG{'INT'} = \&shutdown;
$SIG{'QUIT'} = \&shutdown;
my $running = 1;
while ($running) {
$agent->agent_check_and_process(1);
}
$agent->shutdown();
sub shutdown {
# Shutdown requested
$running = 0;
unlink $pidfile if -e $pidfile;
}
#muninwalk
my @collect;
sub munin_fetch {
my $SOCKET = IO::Socket::INET -> new ( PeerAddr => $Munin{HOST},
PeerPort => $Munin{PORT},
Proto => 'tcp',
Timeout => '10',
Type => SOCK_STREAM,
) or die "Cannot create socket - $@\n";
my $tmp = <$SOCKET>;
while (my $fetch = shift(@_)) {
my $obj = '';
if ($fetch =~ /^(\w+)(\.)(\w+)$/ ) {
($fetch,$obj) = ($1,$3);
}
$SOCKET->print("fetch $fetch\n");
select($SOCKET);
select(STDOUT);
while (<$SOCKET> ) {
chomp;
$_ =~ s/(.value)//;
if ($_ =~ /^(.*)(\s)(.+)$/) {
if (($1 eq '# Unknown') or ($1 eq '# Bad')) {
push (@collect,$fetch.$delimiter.'NULL');
} else {
if (!$obj or ($1 eq $obj)) {
push (@collect,$fetch.".".$1.$delimiter.$3);
}
}
} else {
last;
}
}
}
$SOCKET->print("quit\n");
$SOCKET->close();
return \@collect if @collect;
}
=head1 NAME
munin2snmp - SNMP Agent to query munin-node over snmp
=head1 REQUIREMENTS
Net::SNMP, Getopt::Long, Pod::Usage perl modules, munin-node with some plugins
=head2 Example configuration
/etc/snmp/snmpd.conf
master agentx
agentAddress udp:127.0.0.1:161
rocommunity public 127.0.0.1
On a newer system it is enough to define "master" option only
MUNIN-MIB should be installed on the client,
it goes to /usr/local/share/snmp/mibs or /usr/share/munin/mibs
or another place where snmpd expects to find the MIB files.
See also http://www.net-snmp.org/wiki/index.php/FAQ:MIBs_03
It is possible to start munin2snmp as non-root user, for example
run munin2snmp as Debian-snmp user on Debian Stretch:
fix the /var/agentx permissions:
chmod g+rx /var/agentx
chgrp Debian-snmp /var/agentx
add to /etc/snmp/snmpd.conf:
master agentx
agentXperms 0640 0550 Debian-snmp Debian-snmp
restart snmpd and start the agent as Debian-snmp:
su -l Debian-snmp -s /bin/bash -c "/tmp/munin2snmp.pl --pidfile /tmp/munin2snmp.pid --plugins iostat,vmstat"
=head2 Usage
After setting up snmpd, start the agent:
./munin2snmp
Now one can query the agent
snmpwalk -v 2c -mMUNIN-MIB -c public localhost .1.3.6.1.4.1.123456.100.1.1
where "1.3.6.1.4.1.123456.100.1.1" is example OID selected as the base
tree for the agent.
Change OBJECT IDENTIFIER in the MUNIN-MIB file if you plan to use a different OID.
You might need to change the host, port, oidbase and munin_plugins you want to use.
The defaults:
$Munin{PORT} = '4949';
$Munin{HOST} = 'localhost'
$oidbase = ".1.3.6.1.4.1.123456.100.1.1"
@munin_plugins = qw ( load cpu df );
One can override the defaults by creating /etc/munin2snmp.conf file with the following
configuration options:
munin_port = [port]
munin_host = [host]
base_oid = [oid]
munin_plugins = [comma separated list of munin-node plugins]
Or by specifying the parameters, see munin2snmp --help for the usage
=head1 ACKNOWLEDGEMENTS
Heavily inspired by
Vincent Bernat: https://github.com/vincentbernat/extend-netsnmp
and Masahito Zembutsu: https://github.com/zembutsu/muninwalk
=head1 LICENSE
ISC License (ISC)
Copyright (c) 2016, Alex Mestiashvili <mailatgoogl@gmail.com>
Permission to use, copy, modify, and/or distribute this software for any
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
Reference in New Issue View Git Blame Copy Permalink