Frey/Shell/sar.pm

package Frey::Shell::sar;
use Moose;

extends 'Frey';
with 'Frey::Web';
#with 'Frey::Storage';

has sar_command => (
        is => 'rw',
        isa => 'Str',
        required => 1,
        default => 'sar',
);

sub as_sponge {
        my ($self,$opts) = @_;

        $opts ||= '-u';

        my @rows;
        my @name;

        my $cmd = $self->sar_command . ' ' . $opts;
        warn "# cmd: $cmd";

        my $date = '1970-01-01T';

        open(my $fh, '-|', $cmd) || die "can't open pipe to $cmd $!";
        while(<$fh>) {
                chomp;
                if ( m{(\d\d)/(\d\d)/(\d\d\d\d)$} ) {
                        $date = "$3-$1-$2T";
                        warn "# date $date";
                }
                next unless m{^\d\d:\d\d:\d\d};
                my @l = split(/\s+/,$_);
                if ( $l[$#l] =~ m{_([^_]+)_} ) {
                        warn "# header $1 ",join('|', @l);
                        $l[0] =~ s{00:00:01}{time} || die "can't locate time column in header";
                        delete( $l[$#l] );
                        @name = @l;
                        next;
                }

                $l[0] = $date . $l[0];

                push @rows, [ @l ];
        }

        return {
                rows => \@rows,
                NAME => \@name,
        }
}

1;
1	package Frey::Shell::sar;
2	use Moose;
3
4	extends 'Frey';
5	with 'Frey::Web';
6	#with 'Frey::Storage';
7
8	has sar_command => (
9	is => 'rw',
10	isa => 'Str',
11	required => 1,
12	default => 'sar',
13	);
14
15	sub as_sponge {
16	my ($self,$opts) = @_;
17
18	$opts \|\|= '-u';
19
20	my @rows;
21	my @name;
22
23	my $cmd = $self->sar_command . ' ' . $opts;
24	warn "# cmd: $cmd";
25
26	my $date = '1970-01-01T';
27
28	open(my $fh, '-\|', $cmd) \|\| die "can't open pipe to $cmd $!";
29	while(<$fh>) {
30	chomp;
31	if ( m{(\d\d)/(\d\d)/(\d\d\d\d)$} ) {
32	$date = "$3-$1-$2T";
33	warn "# date $date";
34	}
35	next unless m{^\d\d:\d\d:\d\d};
36	my @l = split(/\s+/,$_);
37	if ( $l[$#l] =~ m{_([^_]+)_} ) {
38	warn "# header $1 ",join('\|', @l);
39	$l[0] =~ s{00:00:01}{time} \|\| die "can't locate time column in header";
40	delete( $l[$#l] );
41	@name = @l;
42	next;
43	}
44
45	$l[0] = $date . $l[0];
46
47	push @rows, [ @l ];
48	}
49
50	return {
51	rows => \@rows,
52	NAME => \@name,
53	}
54	}
55
56	1;