diff options
Diffstat (limited to 'src/mrtg2pcp/mrtg2pcp')
| -rwxr-xr-x | src/mrtg2pcp/mrtg2pcp | 144 |
1 files changed, 144 insertions, 0 deletions
diff --git a/src/mrtg2pcp/mrtg2pcp b/src/mrtg2pcp/mrtg2pcp new file mode 100755 index 0000000..5fac924 --- /dev/null +++ b/src/mrtg2pcp/mrtg2pcp @@ -0,0 +1,144 @@ +#!/usr/bin/perl +# +# Copyright (c) 2010 Josef 'Jeff' Sipek <jeffpc@josefsipek.net> +# +# This program is free software; you can redistribute it and/or modify it +# under the terms of the GNU General Public License as published by the +# Free Software Foundation; either version 2 of the License, or (at your +# option) any later version. +# +# This program is distributed in the hope that it will be useful, but +# WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY +# or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License +# for more details. +# + +use strict; +use warnings; + +use PCP::LogImport; + +if ($#ARGV != 4) { + print "Usage: mrtg2pcp hostname devname timezone infile outfile\n"; + exit(1); +} + +# Note: these match the linux pmda, change to your heart's content +my $domain = 60; +my $cluster = 3; +my $in_item = 0; +my $out_item = 8; +my $indomid = 3; + +# the internal instance id +my $intinstid= 1; + +my $hostname=$ARGV[0]; +my $devname=$ARGV[1]; +my $zone=$ARGV[2]; +my $infile=$ARGV[3]; +my $outfile=$ARGV[4]; + +# first, read the input file +open(INFILE, "<$infile") or die "open($infile): $!"; + +<INFILE>; # skip the first line + +my @lines = <INFILE>; # read the remainder into memory +@lines = reverse(@lines); + +close(INFILE) or die "close($infile): $!"; + +# now the PCP part +pmiStart($outfile, 0) >= 0 + or die "pmiStart($outfile, 0): " . pmiErrStr(-1) . "\n"; + +pmiSetHostname($hostname) == 0 + or die "pmiSetHostname($hostname): ". pmiErrStr(-1) . "\n"; + +pmiSetTimezone($zone) == 0 + or die "pmiSetTimezone($zone): ". pmiErrStr(-1) . "\n"; + +my $indom = pmInDom_build($domain, $indomid); +pmiAddMetric("network.interface.in.bytes", + pmid_build($domain,$cluster,$in_item), PM_TYPE_U64, $indom, + PM_SEM_COUNTER, pmiUnits(1,0,0,PM_SPACE_BYTE,0,0)) == 0 + or die "pmiAddMetric(network.interface.in.bytes, ...): " . pmiErrStr(-1) . "\n"; +pmiAddMetric("network.interface.out.bytes", + pmid_build($domain,$cluster,$out_item), PM_TYPE_U64, $indom, + PM_SEM_COUNTER, pmiUnits(1,0,0,PM_SPACE_BYTE,0,0)) == 0 + or die "pmiAddMetric(network.interface.out.bytes, ...): " . pmiErrStr(-1) . "\n"; + +pmiAddInstance($indom, $devname, $intinstid) >= 0 + or die "pmiAddInstance(..., ".$devname.", $intinstid): " . pmiErrStr(-1) . "\n"; + +my $ihndl = pmiGetHandle("network.interface.in.bytes", $devname); +my $ohndl = pmiGetHandle("network.interface.out.bytes", $devname); + +my @prev = (); +my $ictr = 0; +my $octr = 0; +foreach (@lines) { + my @info = split(/ /); + + if (scalar(@prev) > 0) { + $ictr += $info[1] * ($info[0] - $prev[0]); + $octr += $info[2] * ($info[0] - $prev[0]); + } + + pmiPutValueHandle($ihndl, $ictr); + pmiPutValueHandle($ohndl, $octr); + + pmiWrite($info[0], 0) >= 0 + or die "pmiWrite: @ ".$info[0].": " . pmiErrStr(-1) . "\n"; + + @prev = @info; +} + + +pmiEnd(); + +=pod + +=head1 NAME + +mrtg2pcp - Import mrtg data and create a PCP archive + +=head1 SYNOPSIS + +B<mrtg2pcp> I<hostname> I<devname> I<timezone> I<infile> I<outfile> + +=head1 DESCRIPTION + +B<mrtg2pcp> is intended to read an MRTG log file as created by B<mrtg>(1) +and translate this into a Performance Co-Pilot (PCP) archive with the +basename I<outfile>. The I<hostname>, I<devname>, and I<timezone> arguments +specify information about the system for which the statistics were gathered. + +The resultant PCP achive may be used with all the PCP client tools +to graph subsets of the data using B<pmchart>(1), +perform data reduction and reporting, filter with +the PCP inference engine B<pmie>(1), etc. + +A series of physical files will be created with the prefix I<outfile>. +These are I<outfile>B<.0> (the performance data), +I<outfile>B<.meta> (the metadata that describes the performance data) and +I<outfile>B<.index> (a temporal index to improve efficiency of replay +operations for the archive). If any of these files exists already, +then B<mrtg2pcp> will B<not> overwrite them and will exit with an error +message of the form + +__pmLogNewFile: "blah.0" already exists, not over-written + +B<mrtg2pcp> is a Perl script that uses the PCP::LogImport Perl wrapper +around the PCP I<libpcp_import> +library, and as such could be used as an example to develop new +tools to import other types of performance data and create PCP archives. + +=head1 SEE ALSO + +B<logimport>(3), +B<PCP::LogImport>(3pm), +B<pmchart>(1), +B<pmie>(1) +B<pmlogger>(1). |