扫描apache日志，寻找type==1的日志，写到数据库里.代码,Perl代码库,德仔网

代码语言

代码分类

【Perl】扫描apache日志，寻找type==1的日志，写到数据库里.

作者:gogo / 发布于2014/1/17/ 743

扫描apache日志，寻找type==1的日志，写到数据库里.

#! /usr/bin/perl -w

useDBI;

useBenchmark;

$apache_log_file_path="/usr/local/apache/logs/access_log";

my$WARN_SCAN_TIME="/usr/local/apache/logs/warn_scan_time";

$date_pattern="\\d+\\/\\w+\\/\\d+\:\\d+\:\\d+\:\\d+";

if(open(WARN_TIME,$WARN_SCAN_TIME)){

print"open warn_sacn_time file success\n";

}else{

die"can't open warn_sacn_time file";

}

$warn_line=<WARN_TIME>;

$warn_line=~ qr/$date_pattern/;

my$time_string=$&;



if(open(APACHE_LOG_FILE,$apache_log_file_path)){

print"open apache log sucess";

}else{

die"can't open apache_log_file $!\n";

}

$date_time;

$time_flag=1;

my$startime= new Benchmark;

my$type;

$pattern="([\\w+||_]+=\\w+)([&]?[\\w+||_]+=[\\w||\\[||\\]||\\%||\\\\||_||\"||\:||=||-]+)*";

my$dbh= DBI->connect("DBI:mysql:database=botest:host=192.168.65.128","root","",{"RaiseError"=> 1});

my$sqr;

my$sqr_query;

LINE:while($line=<APACHE_LOG_FILE>){

if($line=~ qr/$date_pattern/){

$date_time=$&;

}

if($time_flag==1){

if($date_timeeq$time_string){

$time_flag=0;

nextLINEif$time_flag==0;

}

}

if($time_flag==0){

if($line=~ qr/type=([0||1||2||3])/) {

$type=$1;

}

nextLINEif$type!=1;

$taskId;

if($line=~ qr/task_id=([0-9]+)/){

$taskId=$1;

}

$sqr_query=$dbh->prepare("select * from warn_set where task_id=?");

$sqr_query->execute($taskId);

($id,$warn_method,$interval_time,$warn_total_times,$task_id) =$sqr_query->fetchrow_array;

$sqr_query->finish();

if($line=~ qr/$pattern/){

$temp_line=$&;

$temp_line=~ s/%20/ /g;

my@array=(split('&',$temp_line));

my$temp;

my@sql_field_value_array;

my$sql_field="(warn_method,last_warn_time,interval_time,warn_total_times,warn_times,";

my$sql_value="('$warn_method.',CURRENT_TIMESTAMP,'$interval_time','$warn_total_times','0',";

my$flage=1;

my$sql="insert into ";

foreach$temp(@array){

@sql_field_value_array=(split('=',$temp));

if($flage==0){

$sql_field.=",".$sql_field_value_array[0];

$sql_value.=","."'$sql_field_value_array[1]'";

}else{

$sql_field.=$sql_field_value_array[0];

$sql_value.="'".$sql_field_value_array[1]."'";

$flage=0;

}

}

$sql_field.=",status)";

$sql_value.=",'1')";

$sql.="warn $sql_field values $sql_value";

$sqr=$dbh->prepare($sql);

$sqr->execute();

}

}

}

open(OUTFILE,">$WARN_SCAN_TIME") ||die("Cannot open files\n");

printOUTFILE ($date_time);

printf"** %s\n\n", timestr(timediff(new Benchmark,$startime));

$dbh->disconnect();

试试其它关键字

同语言下

可能有用的

gogo贡献的其它代码(7)