【Message::Passing系列】过滤器实例

    #!/usr/bin/perl
    package Message::Passing::Filter::GrokLike;
    use Moo;
    use MooX::Types::MooseLike::Base qw/ ArrayRef Str /;
    use List::MoreUtils qw/ uniq /;
    use DateTime;
    use Regexp::Log::Nginx;
    use namespace::clean -except => 'meta';
    with 'Message::Passing::Role::Filter';
    has format => (
        is => 'ro',
        isa => Str,
        default => sub { '%date %status %remotehost %domain %request %originhost %responsetime %upstreamtime %bytes %referer %useragent %xforwarderfor' },
    );
    has capture => (
        is => 'ro',
        isa => ArrayRef,
        default => sub { [ 'ts', 'status', 'remotehost', 'url', 'oh', 'responsetime', 'upstreamtime', 'bytes' ] },
    );
    has _grok => (
        is => 'ro',
        lazy => 1,
        builder => '_build_grok',
    );
    sub _build_grok {
        my $self = shift;
        my $rln = Regexp::Log::Nginx->new(
            format  => $self->format,
            capture => $self->capture,
        );
        return $rln;
    };
    sub filter {
        my ($self, $message) = @_;
        my @fields = $self->_grok->capture;
        my $re = $self->_grok->regexp;
        my %data;
        @data{@fields} = $message->{'@message'} =~ m/$re/;
        $message->{'@fields'} = {
            %data,
            responsetime => $data{'responsetime'} + 0,
            upstreamtime => $data{'upstreamtime'} + 0,
            bytes        => $data{'bytes'}        + 0,
        };
        $message;
    };
    true;