convert atopsar output to influxdb

diff --git a/atop2influx.pl b/atop2influx.pl
new file mode 100755 (executable)
index 0000000..bd26ad5
--- /dev/null
+++ b/atop2influx.pl
@@ -0,0 +1,101 @@
+#!/usr/bin/perl
+use warnings;
+use strict;
+use Time::Local;
+
+use Data::Dump;
+sub XXX { warn Data::Dump::dump( @_ ) };
+
+my $measurement = 'debug';
+my $host;
+my $yyyymmdd;
+
+my ($dd,$mm,$yyyy);
+my ($hour,$min,$sec)=(0,0,0);
+my @cols;
+my $time;
+sub update_time {
+       #warn "# time $yyyy-$mm-$dd $hour:$min:$sec $time\n";
+       $time = timelocal($sec,$min,$hour,$dd,$mm-1,$yyyy) * 1000_000_000;
+       return $time;
+}
+
+while(<>) {
+       chomp;
+       next if /^$/;
+
+       #warn "#[$_]\n";
+
+       my @vals;
+
+       if ( /^(\w+)\s+(\S+)\s+(.+)\s+(\w+)\s+(\d\d\d\d)\/(\d\d)\/(\d\d)$/ ) {
+               $host = $1;
+               @cols = qw( kernel build arch );
+               @vals =   ( qq{"$2"}, qq{"$3"}, qq{"$4"} ); # must quote all this as strings for influx
+               ( $yyyy, $mm, $dd ) = ( $5, $6, $7 ); update_time;
+
+       } elsif ( m/analysis date: (\S+)/ ) {
+               ( $yyyy, $mm, $dd ) = split(/\//, $1, 3); update_time;
+               next;
+
+       } elsif ( m/^00:00:01\s+(.+)_(\w+)_/ ) {
+               $measurement = $2;
+               my $cols = $1;
+               $cols =~ s/(in|out):\s+(\w+)/$1_$2/g; # ipv4, ipv6
+               @cols = split(/\s+/, $cols);
+               next;
+
+       } elsif ( m/^(\d\d:\d\d:\d\d)\s+(.+)/ ) {
+               ( $hour, $min, $sec )  = split(/:/, $1, 3); update_time;
+               @vals = split(/\s+/, $2);
+       } elsif ( m/^\s+(.+)/ ) {
+               @vals = split(/\s+/, $1);
+       } else {
+               die "UNPARSED: $_\n";
+       }
+
+       next unless @vals;
+
+       next if $measurement =~ /top3/; # FIXME this isn't parsed yet
+
+       #XXX { cols => \@cols, vals => \@vals };
+       print "atop_$measurement,host=$host";
+       my $d = " ";
+       foreach my $i ( 0 .. $#cols ) {
+               if ( my $c = $cols[$i] ) {
+                       my $s = '';
+
+                       if ( $c =~ m/(cpu|disk|interf)/ ) { ; # XXX tag
+                               ($d,$s) = (',',' ');
+                       }
+
+                       $c =~ s/^%//;
+                       $c =~ s{/s$}{};
+                       $c =~ s/\W+/_/g;
+
+                       my $v = $vals[$i];
+                       die "line: [$_]\nno vals[$i] in ",Data::Dump::dump( @vals ) if ! defined $v;
+
+                       #$v *= 1024 * 1024 if $v =~ s/M$//;
+                       $v =~ s/M$//;
+                       $v =~ s/%$//;
+
+                       $v =~ s/\s/\\ /g unless $v =~ m/"/;
+
+                       next if $c eq "busy" && $v eq "?";
+
+                       print "$d$c=$v$s";
+
+                       $d ||= ',';
+                       $d = '' if $s eq " "; # move to values
+                       $d = ',' if $d eq " "; # move to values
+
+
+               } else {
+                       die "line: [$_]\nno cols[$i] in ",Data::Dump::dump( @cols );
+               };
+               
+       }
+       print " $time\n";
+}
+