File Coverage

blib/lib/Mojo/Zabbix/APP.pm

Criterion	Covered	Total	%
statement	15	123	12.2
branch	0	26	0.0
condition	0	10	0.0
subroutine	5	19	26.3
pod	0	14	0.0
total	20	192	10.4

package Mojo::Zabbix::APP;

use strict;
use warnings;
use Mojo::Zabbix;
use utf8;

use POSIX qw(strftime);

require Exporter;

our @ISA     = qw(Exporter);
our @EXPORT  = qw(initZ pVersion getAllhost getname getItem pHitems pTriggers);

=head1 NAME

Mojo::Zabbix::APP - The application module of Mojo-Zabbix .Using to get
data from zabbix data include host,items, Triggers and warns and so on.


=head1 VERSION

Version 0.03

=cut

our $VERSION = '0.03';


=head1 SYNOPSIS

    use Mojo::Zabbix::APP;

    my @myzinfo = ; ##(get zabbix info from __DATA__ )

# Define for debug and traceing processe infomaition。（打开调试和跟踪）

   my $DEBUG=0;
   my $TRACE=0;

#my @myzinfo = ('test1 http://test1/zabbix testuser pass');
# @可以定义为多行数据，格式按照这种，一个zabbix 服务地址一个

  for (@myzinfo) {
    next if /^#/;
    next if /^\s*$/;
    my ( $name, $url,$user, $pass ) = split;
    print "\n$name\n";
    my $z;

    eval { $z = initZ( $url,$user,$pss ); };

    if ($@) {

        print "Error $@!\n";

    } else {

      ## Print the version of zabbix api. 打印zabbix 版本

        pVersion($z);

       ## Print all host lists。 获取所有的主机列表

       print  getAllhost($z);

       ## Print warning info of Triggers。打印取得的所有触发器告警信息
       pTriggers($z);

       ## Print the history data of given items, default for past 24 hours.
       ## 打印给定时间段的item历史数据，如果默认不给时间默认为过去24小时内的
       pHitems($z);

    }
 }

=cut

#### 初始化的Mojo::zabbix ，必须安装Mojo::zabbix模块,可用cpanm Mojo::zabbix 安装
my %EVcache;
my %HTcache;
## 缓存hash 对事件id进行缓存，防止重复调用
my $DEBUG=0;
my $TRACE=0;
sub initZ {

    my ( $url, $user, $pass ) = @_;
    print "debug-initZ { parameter } : $url, $user, $pass \n" if $DEBUG;
    my $zbbix = Mojo::Zabbix->new(
        url      => $url,
        username => $user,
        password => $pass,
        debug    => $DEBUG,
        trace    => $TRACE,
    );

}

### 打印zabbix 版本

sub  pVersion {

    my $z=shift;
    my $r = $z->get(
       "apiinfo.version",
    );

    my $result = $r->{'result'};
    return $result,"\n";
}



### 打印给定时间段的item历史数据，如果默认不给时间默认为过去24小时内的
sub  pHitems {

     my ($z,$host,$key,$btime,$ltime)=@_;
     $host  //= '192.168.1.1';
     $key //='net.if.in[bond0]';
     $btime //= time() - 1 * 3600;
     $ltime //= time();
     my $info;
     my $hostid = gethostID( $z, $host );
     my ($name,$itemid) = getItemID( $z, $hostid, $key );
     $info="The Item of $name-$key \n\n";
     print "debug-PHitems { parameter } : $host $key $btime $ltime \n" if $DEBUG;
     my $v =getHisv( $z, $hostid, $itemid, $btime,$ltime);

        for ( sort {$b <=> $a} @{$v} ) {

            #print Dumper($_);
            my $stime = strftime( "%Y-%m-%d %H:%M:%S", localtime( $_->[0] ) );
            $info.= "$stime  $_->[1] \n";

        }
     return $info;
}

### 打印取得的所有触发器告警信息

sub pTriggers {

    my $z=shift;
    my $info;
    my $reslut = getTriggers($z);
    $info="\nWarning info of Triggers \n\n";
    for ( sort { $b <=> $a } keys %{$reslut} ) {

        $info.= "$reslut->{$_}";

    }
   return $info;
}
##### 获取给定主机和key值的所有监控项以及当前值


sub getItem {

    my ( $z, $host, $key ) = @_;

######bug fox : retun if host not exist

    return unless gethostID( $z, $host );

    my $hostid =gethostID( $z, $host );
    my $r = $z->get(
        "item",
        {

            output => [ "name", "key_", "prevvalue" ],
            search  => { "key_" => $key },
            hostids => $hostid,
            #    limit => 10,

        },
    );

    my $result = $r->{'result'};
    my $sresult;

    $sresult .= "$_->{'name'} - { $_->{'key_'} } : $_->{'prevvalue'} \n"
      for ( @{$result} );

    return $sresult;
}

sub getItemID {

    my ( $z, $hostid, $key ) = @_;
    print "DEBUG-function(getItemID): $z, $key \n"  if $DEBUG;
    my $r = $z->get(
        "item",
        {

            output  => ["itemids","name"],
            search  => { "key_" => $key },
            hostids => $hostid,

        },
    );

    my $result = $r->{'result'};
    my $sresult;

    $sresult = $result->[0]->{'itemid'};

    return ($result->[0]->{'name'},$result->[0]->{'itemid'});
}

sub getHisv {

    my ( $z, $hostid, $itemid, $btime, $ltime ) = @_;
    print "DEBUG-function(-getHist): $z, $hostid, $itemid, $btime, $ltime \n"  if $DEBUG;
    my $r = $z->get(
        "history",
        {
            #        history => 0,
            itemids   => $itemid,
            time_from => $btime,
            time_till => $ltime,
            output    => "extend",
            hostids   => $hostid,

        },
    );

    my $result = $r->{'result'};
    my $sresult;

#$sresult.="$_->{'name'} - $_->{'_key'} : $_->{'prevvalue'} \n" for(@{$result});
#print Dumper($result);
    for ( @{$result} ) {

        push @{$sresult}, [ $_->{'clock'}, $_->{'value'} ];

    }
    return $sresult;
}

#### 获取给定主机（ip）的主机号
sub gethostID {

    my ( $z, $host ) = @_;
    my $ckey=$host;
    unless(exists $HTcache{$ckey}) {
     print "DEBUG-function(gethostID): $z, $host \n" if $DEBUG;
     my $r = $z->get("host",
        {
            filter => {
                host => $host,
            },
            output => ["hostid"],
        },
     );
      $HTcache{$ckey}=$r->{'result'}->[0]->{'hostid'} if $r->{'result'};
    }
    return $HTcache{$ckey};
}

sub getname {

    my ( $z, $host ) = @_;
     print "DEBUG-function(gethostname): $z, $host \n" if $DEBUG;
     my $r = $z->get("host",
        {
            filter => {
                host => $host,
            },
            output => ["name"],
        },
     );
      #use Data::Dumper;
      return $r->{'result'}->[0]->{'name'} if $r->{'result'};
}
#### 获取所有的主机列表

sub getAllhost {

    my $z = shift;
    my $r = $z->get("host",
        {
            filter => undef,
            search => undef,
            output => ["host","name"],
        },
    );

    my $hresult;
    my $host = $r->{'result'};
    for (@$host) {
        $hresult .= $_->{'host'} .": $_->{'name'}". "\n";
    }

    return $hresult;
}

####获取所有的有问题触发警告信息,返回一个包含时间、主机ip和描述的哈希引用

sub getTriggers {
    my $z        = shift;
    my $ysterday = time() - 24 * 3600;
    my $r        = $z->get(
        "trigger",
        {
            filter => {
                value                    => 1,
                only_true                => 1,
                withUnacknowledgedEvents => 1,
            },

            # lastChangeSince => $ysterday,
            output     => [ "triggerid", "description", "priority" ],
            sortfield  => "triggerid",
            sortorder  => "DESC",
            expandData => "host",

        },
    );
    my $hresult;
    my $host = $r->{'result'};
    for (@$host) {
        my $etime = getTgtime( $z, $_->{'triggerid'}, $_->{'host'} );
        next unless $etime;
        my $time = strftime( "%Y-%m-%d %H:%M:%S", localtime($etime) );
        $hresult->{$etime} =
          "$time : $_->{'host'}: " . $_->{'description'} . "\n";
    }

    return $hresult;
}

### 给定触发器，触发器处罚时间(限制24小时候内的).
sub getTgtime {

    my ( $z, $tgid, $host ) = @_;

    my $hostid=gethostID($z,$host);
    my $ysterday = time() - 24 * 3600;
    my $vkey=$tgid.$hostid;
    unless(exists $EVcache{$vkey}) {
     my $r        = $z->get(
        "event",
        {
            filter => {

                # value => 1,
                # objectids => '19011' ,
                # triggerids  => '19011' ,
                #source  => 0,
            },

            objectids  => $tgid,
            triggerids => $tgid,
            time_from  => $ysterday,
            hostids => $hostid,
            #select_acknowledges => "extend",
            output              => "extend",

            sortfield =>"eventid",
            sortorder => "DESC",
            #  expandData=>"host",

        },
    );
    $EVcache{$vkey}=$r->{'result'}->[0]->{'clock'} if $r->{'result'};
   }
   return $EVcache{$vkey};
}
sub getEvent {
    my $z        = shift;
    my $ysterday = time() - 1 * 3600;
    my $r        = $z->get(
        "event",
        {
            filter => {

                # value => 1,
                acknowledged => 0,

                #time_from=> "$ysterday",
            },
            time_from           => "$ysterday",
            output              => "extend",
            source              => 0,
            select_acknowledges => "extend",

            #sortfield =>["clock", "eventid"],
            #sortorder => "DESC",
            #  expandData=>"host",

        },
    );
    my $host    = $r;
    my $hresult = Dumper($r);
    return $hresult;
}

sub getAlert {
    my $z        = shift;
    my $ysterday = time() - 24 * 3600;
    my $r        = $z->get(
        "alert",
        {
            #filter => {
            # value => 1,
            #time_from=> "$ysterday",
            #},
            #time_from=> "$ysterday",
            # actionids =>"3",
            output => "extend",

            #source => 0 ,
            sortfield => ["clock"],
            sortorder => "DESC",

            #  expandData=>"host",

        },
    );
    my $host    = $r;
    my $hresult = Dumper($r);
  #  print $hresult;
    return $hresult;
}

=head1 AUTHOR

ORANGE, C<<  >>

=head1 BUGS

Please report any bugs or feature requests to C, or through
the web interface at L.  I will be notified, and then you'll
automatically be notified of progress on your bug as I make changes.




=head1 SUPPORT

You can find documentation for this module with the perldoc command.

    perldoc Mojo::Zabbix::APP


You can also look for information at:

=over 4

=item * RT: CPAN's request tracker (report bugs here)

L

=item * AnnoCPAN: Annotated CPAN documentation

L

=item * CPAN Ratings

L

=item * Search CPAN

L

=back


=head1 ACKNOWLEDGEMENTS


=head1 LICENSE AND COPYRIGHT

Copyright 2016 ORANGE.

This is free software; you can redistribute it and/or modify
it under the same terms as the Perl 5 programming language system itself.

=cut

1;