mirror of
https://github.com/munin-monitoring/contrib.git
synced 2025-07-22 02:51:03 +00:00
Merge pull request #798 from pru-mike/add_upsmonpro_plugin
Added plugin for Powercom UPSMON PRO software
This commit is contained in:
commit
bafe8ce044
1 changed files with 222 additions and 0 deletions
222
plugins/ups/upsmonpro_
Normal file
222
plugins/ups/upsmonpro_
Normal file
|
@ -0,0 +1,222 @@
|
|||
#!/usr/bin/perl
|
||||
|
||||
=head1 NAME
|
||||
|
||||
upsmonpro_ - Munin plugin to monitor Powercom UPS via UPSMON PRO program L<http://www.pcm.ru/support/soft/>
|
||||
|
||||
=head1 INSTALLATION
|
||||
|
||||
/etc/munin/plugins/upsmonpro_load -> /usr/share/munin/plugins/upsmonpro_
|
||||
/etc/munin/plugins/upsmonpro_status -> /usr/share/munin/plugins/upsmonpro_
|
||||
/etc/munin/plugins/upsmonpro_temp -> /usr/share/munin/plugins/upsmonpro_
|
||||
/etc/munin/plugins/upsmonpro_voltage -> /usr/share/munin/plugins/upsmonpro_
|
||||
|
||||
=head1 CONFIGURATION
|
||||
|
||||
Environment variables:
|
||||
|
||||
host - UPSMON PRO server host, default localhost
|
||||
port - UPSMON PRO port, default 2601
|
||||
|
||||
Example configuration (optional):
|
||||
|
||||
[upsmonpro_*]
|
||||
env.host localhost
|
||||
env.port 2601
|
||||
|
||||
=head1 MAGIC MARKERS
|
||||
|
||||
#%# family=auto
|
||||
#%# capabilities=autoconf
|
||||
#%# capabilities=suggest
|
||||
|
||||
=head1 AUTHOR
|
||||
|
||||
Copyright (C) 2017 pru.mike@gmail.com
|
||||
|
||||
=head1 LICENSE
|
||||
|
||||
GPLv2.
|
||||
|
||||
=cut
|
||||
|
||||
use strict;
|
||||
use warnings;
|
||||
use feature qw/say/;
|
||||
use Munin::Plugin;
|
||||
use IO::Socket::INET;
|
||||
use Time::HiRes qw/usleep/;
|
||||
use English qw/-no-math-vars/;
|
||||
our $VERSION = '0.0.1';
|
||||
$OUTPUT_AUTOFLUSH++;
|
||||
|
||||
our $DEFAULT_HOST = 'localhost';
|
||||
our $DEFAULT_PORT = 2601;
|
||||
our %TYPES = (
|
||||
voltage => [qw/input output/],
|
||||
load => [qw/battery_load battery_capacity/],
|
||||
temp => [q/temp/],
|
||||
status => [qw/power_failure low_battery voltage_status ups_status battery_test/]
|
||||
);
|
||||
our @TYPES = sort keys %TYPES;
|
||||
my %DISPATCH_TABLE = ();
|
||||
my $pkg = __PACKAGE__;
|
||||
|
||||
$DISPATCH_TABLE{"${pkg}::run_suggest"} = \&run_suggest;
|
||||
$DISPATCH_TABLE{"${pkg}::run_autoconf"} = \&run_autoconf;
|
||||
for my $t (@TYPES) {
|
||||
$DISPATCH_TABLE{"${pkg}::run_config_$t"} = \&{"run_config_$t"};
|
||||
$DISPATCH_TABLE{"${pkg}::run_autoconf_$t"} = \&run_autoconf;
|
||||
$DISPATCH_TABLE{"${pkg}::run_default_$t"} = sub {
|
||||
run_default(@{ $TYPES{$t} });
|
||||
};
|
||||
}
|
||||
|
||||
find_key($ARGV[0])->();
|
||||
|
||||
sub find_key {
|
||||
my $argv = shift || '';
|
||||
my $type_re = join '|', @TYPES;
|
||||
my $key;
|
||||
if ($argv =~ /(suggest|autoconf)/i) {
|
||||
$key = 'run_' . lc($1);
|
||||
} elsif ($Munin::Plugin::me =~ /upsmonpro_{1,}($type_re)$/) {
|
||||
my $graph = $1;
|
||||
$key = 'run_' . ((grep { $argv eq $_ } qw/autoconf config/) ? $argv : 'default') . "_$graph";
|
||||
} else {
|
||||
die "Could not determine script type [@TYPES] ? name=$Munin::Plugin::me\n";
|
||||
}
|
||||
|
||||
return $DISPATCH_TABLE{"${pkg}::$key"};
|
||||
}
|
||||
|
||||
sub run_config_voltage {
|
||||
print <<'END';
|
||||
graph_title UPS Input/Output Voltage
|
||||
graph_vlabel volt
|
||||
graph_scale no
|
||||
graph_category sensors
|
||||
input.label input
|
||||
input.info Input Voltage
|
||||
input.type GAUGE
|
||||
output.label output
|
||||
output.info Output Voltage
|
||||
output.type GAUGE
|
||||
END
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub run_config_temp {
|
||||
print <<'END';
|
||||
graph_title UPS Temperature
|
||||
graph_vlabel celsius
|
||||
graph_scale no
|
||||
graph_category sensors
|
||||
temp.label temperature
|
||||
temp.type GAUGE
|
||||
END
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub run_config_load {
|
||||
print <<'END';
|
||||
graph_title UPS Battery Load/Capacity
|
||||
graph_vlabel precent%
|
||||
graph_scale no
|
||||
graph_category sensors
|
||||
battery_load.label battery_load
|
||||
battery_load.type GAUGE
|
||||
battery_capacity.label battery_capacity
|
||||
battery_capacity.type GAUGE
|
||||
END
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub run_config_status {
|
||||
print <<'END';
|
||||
graph_title UPS Statuses
|
||||
graph_vlabel status
|
||||
graph_scale no
|
||||
graph_category sensors
|
||||
power_failure.label power_failure
|
||||
power_failure.type GAUGE
|
||||
low_battery.label low_battery
|
||||
low_battery.type GAUGE
|
||||
voltage_status.label voltage_status
|
||||
voltage_status.info 0 normal, 1 boost, 2 buck
|
||||
voltage_status.type GAUGE
|
||||
ups_status.label ups_status
|
||||
ups_status.type GAUGE
|
||||
battery_test.label battery_test
|
||||
battery_test.type GAUGE
|
||||
END
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub run_default {
|
||||
my $host = $ENV{host} || $DEFAULT_HOST;
|
||||
my $port = $ENV{port} || $DEFAULT_PORT;
|
||||
my @val_list = @_;
|
||||
my $r = gather_data($host, $port);
|
||||
for (@val_list) {
|
||||
die "Wrong value: $_" if not exists $r->{$_};
|
||||
say "${_}.value $r->{$_}";
|
||||
}
|
||||
}
|
||||
|
||||
sub run_suggest {
|
||||
local $LIST_SEPARATOR = "\n";
|
||||
say "@TYPES";
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub run_autoconf {
|
||||
if (gather_data($DEFAULT_HOST, $DEFAULT_PORT)->{response} eq 'ok') {
|
||||
say "yes";
|
||||
} else {
|
||||
say "no ($DEFAULT_HOST:$DEFAULT_PORT not response)";
|
||||
}
|
||||
exit(0);
|
||||
}
|
||||
|
||||
sub gather_data {
|
||||
my $host = shift;
|
||||
my $port = shift;
|
||||
my %data = map { ($_ => 'U') } map { @{ $TYPES{$_} } } @TYPES;
|
||||
$data{response} = 'failed';
|
||||
|
||||
my $sock = IO::Socket::INET->new(
|
||||
PeerAddr => $host,
|
||||
Proto => 'udp',
|
||||
PeerPort => $port,
|
||||
Blocking => 0
|
||||
) or die "Cannot create socket: $@";
|
||||
|
||||
my $pattern = pack 'AAAACAAA', split //, 'PCMG1END';
|
||||
$sock->send($pattern) or die "send to $host: $!";
|
||||
usleep(200);
|
||||
my $data;
|
||||
my $buf;
|
||||
while ($sock->read($buf, 32)) {
|
||||
$data .= $buf;
|
||||
}
|
||||
if (defined $data and $data =~ /^PCMR.*END$/) {
|
||||
my @data = unpack('C*', $data);
|
||||
%data = (
|
||||
response => 'ok',
|
||||
input => $data[6] + 256 * $data[5],
|
||||
output => $data[8] + 256 * $data[7],
|
||||
battery_load => $data[11],
|
||||
battery_capacity => $data[12],
|
||||
temp => $data[15],
|
||||
power_failure => ($data[18] ? 1 : 0),
|
||||
low_battery => ($data[19] ? 1 : 0),
|
||||
|
||||
#voltage_status: 0 = normal, 3 = buck, 2 = boost
|
||||
voltage_status => ($data[17] == 0 ? 0 : ($data[17] == 3 ? 2 : 1)),
|
||||
ups_status => ($data[21] ? 1 : 0),
|
||||
battery_test => ($data[23] ? 1 : 0),
|
||||
);
|
||||
}
|
||||
return \%data;
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue