forum.lissyara.su

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

less db_step1.pl
#!/usr/bin/perl
use Mysql;

$dsn = 'DBI:mysql:db_name:localhost';
$db_user = 'user';
$db_pass = 'password';
$dbh = DBI->connect($dsn, $db_user, $db_pass);

$plain_path='/usr/local/var/plain/';
$yesterday=`date -v-1d '+%Y%m%d'`;
chomp($yesterday); $full_path=$plain_path.$yesterday.".fxp1";

$del_query="delete from yesterday;";
$dbh->Query($del_query);

open(F,$full_path) || die "Can't open traffic plain file";
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 yesterday (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);

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

proxy# /usr/local/var/trafd/db_step1.pl
Can't locate object method "Query" via package "DBI::db" at /usr/local/var/trafd/db_step1.pl line 14.
proxy#