forum.lissyara.su

Код: Выделить всё

#!/usr/bin/perl
use mysql;

$dbh=mysql->Connect("","db","login","pass");
$del_query="delete from hourly;";
$dbh->Query($del_query);

$plain_path='/usr/local/var/traffic_plain/';
$lasthour=`date '+%Y%m%d%H'`;
chomp($lasthour);
#$full_path=$plain_path.$lasthour.".ng";


Process($plain_path.$lasthour.".rl0");
Process($plain_path.$lasthour.".sk0");
Process($plain_path.$lasthour.".ng0");
Process($plain_path.$lasthour.".ng1");
Process($plain_path.$lasthour.".ng2");
Process($plain_path.$lasthour.".ng3");
Process($plain_path.$lasthour.".ng4");
Process($plain_path.$lasthour.".ng5");
Process($plain_path.$lasthour.".ng6");
Process($plain_path.$lasthour.".ng7");
#Process($plain_path."20070703.sk1");


sub Process {

my $fn = shift;
open(F,$fn) || die "Can't open traffic plain file ".$fn;
while ($str=<F>)
{
    chomp($str);
    $fi=substr($str,0,1);
    
    if (($fi>='1') && ($fi<='9'))
    {
	@a=split('\s+',$str);
	# @a[0] - src_ip, @a[1] - src_port, @a[2] - dst_ip, @a[3] - dst_port
	# @a[4] - proto,  @a[6] - size of packets
	
	if (@a[1] eq 'client') {
	    $src_port=65535;
	} else {
	    if (@a[1] eq 'none') {
		$src_port=0;
	    } else {
		$src_port=@a[1];
	    }
	}
	
	if (@a[3] eq 'client') {
	    $dst_port=65535;
	} else {
	    if (@a[3] eq 'none') {
		$dst_port=0;
	    } else {
		$dst_port=@a[3];
	    }
	}
	
	$proto=0;
	if (@a[4] eq 'icmp') {
	    $proto=1; }
	if (@a[4] eq 'tcp') {
	    $proto=6; }
	if (@a[4] eq 'udp') {
	    $proto=17; }

	$ins_query="insert into hourly (src_ip, src_port, dst_ip, \
	    dst_port, proto, bytes) values ('".@a[0]."',".$src_port.", \
	    '".@a[2]."',".$dst_port.",".$proto.",".$a[6].");";
	$dbh->Query($ins_query);
    };
};

close(F);

}	

Код: Выделить всё

# ./db_step1.pl
Can't locate object method "Connect" via package "mysql" (perhaps you forgot to load "mysql"?) at ./db_step1.pl line 4.