5 |
|
|
6 |
use IO::Socket; |
use IO::Socket; |
7 |
use Data::Dump qw/dump/; |
use Data::Dump qw/dump/; |
8 |
|
#use StoreToMongoDB; |
9 |
|
|
10 |
my $port = 514; |
my $port = 514; |
11 |
|
|
33 |
my $hostname = gethostbyaddr($ipaddr, AF_INET); |
my $hostname = gethostbyaddr($ipaddr, AF_INET); |
34 |
my $ip = join('.', unpack('C4',$ipaddr)); |
my $ip = join('.', unpack('C4',$ipaddr)); |
35 |
warn "# ",dump( $port, $ipaddr, $hostname, $buf ); |
warn "# ",dump( $port, $ipaddr, $hostname, $buf ); |
36 |
|
|
37 |
if ( $buf=~/<(\d+)>(.*?):(.*)/ ) { |
if ( $buf=~/<(\d+)>(.*?):(.*)/ ) { |
38 |
my $pri=$1; |
my $sev=$1 % 8; |
39 |
my $head=$2; |
my $fac=($1-$sev) / 8; |
40 |
my $msg=$3; |
|
41 |
my $sev=$pri % 8; |
my $log = { |
42 |
my $fac=($pri-$sev) / 8; |
ip => $ip, |
43 |
print dump( $ip, $port, $hostname, $pri, $head, $msg, $sev, $fac, $facilities[$fac] ),$/; |
port => $port, |
44 |
|
hostname => $hostname, |
45 |
|
|
46 |
|
priority => $1, |
47 |
|
severity => $sev, |
48 |
|
facility => $fac, |
49 |
|
header => $2, |
50 |
|
message => $3, |
51 |
|
}; |
52 |
|
print dump( $log ),$/; |
53 |
|
#StoreToMongoDB->insert( $log ); |
54 |
} |
} |
55 |
} |
} |