[서버운영] 아파치로그] sql로 바로 저장.
아래글에 이어 아파치와 php-cli 를 연계하여 로그를 바로 sql 에 저장한다.
예제이므로 DB 클래스와 에러제어 부분은 따로 표기하지 않는다.
PostgreSQL 기준.
httpd.conf
CustomLog "| /etc/apache2/shjsqllog.php" shjsqllog
CREATE TABLE shjlog (
seq SERIAL NOT NULL,
ip CIDR NOT NULL,
port SMALLINT NOT NULL,
bytes BIGINT NOT NULL,
inbytes BIGINT NOT NULL,
outbytes BIGINT NOT NULL,
protocol VARCHAR(30) NOT NULL,
method VARCHAR(10) NOT NULL,
host VARCHAR(200) NOT NULL,
file VARCHAR(300) NOT NULL,
uri VARCHAR(500) NOT NULL,
status SMALLINT NOT NULL,
phpsessid CHAR(32) NOT NULL,
useragent VARCHAR(200) NOT NULL,
referer VARCHAR(500) NOT NULL,
responsetime INTEGER NOT NULL,
datetime TIMESTAMPTZ NOT NULL,
PRIMARY KEY (seq)
);
CREATE INDEX ip_dex ON shjlog (ip);
CREATE INDEX host_dex ON shjlog (host);
CREATE INDEX uri_dex ON shjlog (uri);
CREATE INDEX phpsessid_dex ON shjlog (phpsessid);
CREATE INDEX useragent_dex ON shjlog (useragent);
CREATE INDEX referer_dex ON shjlog (referer);
#!/usr/bin/php
<?php
include_once 'SHJ/debug.inc.php';
include_once 'SHJ/DB/PDOExt.inc.php';
$db = new SHJPDOExt('pgsql', '/etc/apache2/shjlog.ini');
$fields->ip = '';
$fields->port = '';
$fields->bytes = '';
$fields->inbytes = '';
$fields->outbytes = '';
$fields->protocol = '';
$fields->method = '';
$fields->host = '';
$fields->file = '';
$fields->uri = '';
$fields->status = '';
$fields->phpsessid = '';
$fields->useragent = '';
$fields->referer = '';
$fields->responsetime = '';
$fields->datetime = '';
$stmt = $db->insert('shjlog', $fields);
$fp = fopen('php://stdin', 'r');
while(true) {
$line = fgets($fp, 4096);
if(!preg_match('/^ip:"(.*?)" port:"(.*?)" bytes:"(.*?)" inbytes:"(.*?)" outbytes:"(.*?)" protocol:"(.*?)" method:"(.*?)" host:"(.*?)" file:"(.*?)" uri:"(.*?)" status:"(.*?)" phpsessid:"(.*?)" useragent:"(.*?)" referer:"(.*?)" responsetime:"(.*?)" datetime:"(.*?)"$/s', $line, $matches)) {
continue;
}
$fields->ip = $matches[1];
$fields->port = $matches[2];
$fields->bytes = $matches[3];
$fields->inbytes = $matches[4];
$fields->outbytes = $matches[5];
$fields->protocol = $matches[6];
$fields->method = $matches[7];
$fields->host = $matches[8];
$fields->file = $matches[9];
$fields->uri = $matches[10];
$fields->status = $matches[11];
$fields->phpsessid = $matches[12];
$fields->useragent = $matches[13];
$fields->referer = $matches[14];
$fields->responsetime = $matches[15];
$fields->datetime = $matches[16];
try {
$stmt->exec();
} catch(Exception $e) {
$fp2 = fopen('/etc/apache2/shjlogerr.txt', 'w');
fwrite($fp2, $e->getMessage());
fclose($fp2);
$db = new SHJPDOExt('pgsql', '/etc/apache2/shjlog.ini');
$stmt = $db->insert('shjlog', $fields);
try {
$stmt->exec();
} catch(Exception $e) {}
}
}
?>
예제이므로 DB 클래스와 에러제어 부분은 따로 표기하지 않는다.
PostgreSQL 기준.
httpd.conf
CustomLog "| /etc/apache2/shjsqllog.php" shjsqllog
CREATE TABLE shjlog (
seq SERIAL NOT NULL,
ip CIDR NOT NULL,
port SMALLINT NOT NULL,
bytes BIGINT NOT NULL,
inbytes BIGINT NOT NULL,
outbytes BIGINT NOT NULL,
protocol VARCHAR(30) NOT NULL,
method VARCHAR(10) NOT NULL,
host VARCHAR(200) NOT NULL,
file VARCHAR(300) NOT NULL,
uri VARCHAR(500) NOT NULL,
status SMALLINT NOT NULL,
phpsessid CHAR(32) NOT NULL,
useragent VARCHAR(200) NOT NULL,
referer VARCHAR(500) NOT NULL,
responsetime INTEGER NOT NULL,
datetime TIMESTAMPTZ NOT NULL,
PRIMARY KEY (seq)
);
CREATE INDEX ip_dex ON shjlog (ip);
CREATE INDEX host_dex ON shjlog (host);
CREATE INDEX uri_dex ON shjlog (uri);
CREATE INDEX phpsessid_dex ON shjlog (phpsessid);
CREATE INDEX useragent_dex ON shjlog (useragent);
CREATE INDEX referer_dex ON shjlog (referer);
#!/usr/bin/php
<?php
include_once 'SHJ/debug.inc.php';
include_once 'SHJ/DB/PDOExt.inc.php';
$db = new SHJPDOExt('pgsql', '/etc/apache2/shjlog.ini');
$fields->ip = '';
$fields->port = '';
$fields->bytes = '';
$fields->inbytes = '';
$fields->outbytes = '';
$fields->protocol = '';
$fields->method = '';
$fields->host = '';
$fields->file = '';
$fields->uri = '';
$fields->status = '';
$fields->phpsessid = '';
$fields->useragent = '';
$fields->referer = '';
$fields->responsetime = '';
$fields->datetime = '';
$stmt = $db->insert('shjlog', $fields);
$fp = fopen('php://stdin', 'r');
while(true) {
$line = fgets($fp, 4096);
if(!preg_match('/^ip:"(.*?)" port:"(.*?)" bytes:"(.*?)" inbytes:"(.*?)" outbytes:"(.*?)" protocol:"(.*?)" method:"(.*?)" host:"(.*?)" file:"(.*?)" uri:"(.*?)" status:"(.*?)" phpsessid:"(.*?)" useragent:"(.*?)" referer:"(.*?)" responsetime:"(.*?)" datetime:"(.*?)"$/s', $line, $matches)) {
continue;
}
$fields->ip = $matches[1];
$fields->port = $matches[2];
$fields->bytes = $matches[3];
$fields->inbytes = $matches[4];
$fields->outbytes = $matches[5];
$fields->protocol = $matches[6];
$fields->method = $matches[7];
$fields->host = $matches[8];
$fields->file = $matches[9];
$fields->uri = $matches[10];
$fields->status = $matches[11];
$fields->phpsessid = $matches[12];
$fields->useragent = $matches[13];
$fields->referer = $matches[14];
$fields->responsetime = $matches[15];
$fields->datetime = $matches[16];
try {
$stmt->exec();
} catch(Exception $e) {
$fp2 = fopen('/etc/apache2/shjlogerr.txt', 'w');
fwrite($fp2, $e->getMessage());
fclose($fp2);
$db = new SHJPDOExt('pgsql', '/etc/apache2/shjlog.ini');
$stmt = $db->insert('shjlog', $fields);
try {
$stmt->exec();
} catch(Exception $e) {}
}
}
?>
[이 게시물은 관리자님에 의해 2011-10-31 17:30:25 Apache에서 이동 됨]
|
댓글을 작성하시려면 로그인이 필요합니다.
프로그램
태그 필터 (최대 3개)
전체
개발자
소스
기타
mysql
팁자료실
javascript
php
linux
flash
정규표현식
jquery
node.js
mobile
웹서버
os
프로그램
강좌
썸네일
이미지관련
도로명주소
그누보드5
기획자
견적서
계약서
기획서
마케팅
제안서
seo
통계
서식
통계자료
퍼블리셔
html
css
반응형
웹접근성
퍼블리싱
표준화
반응형웹
홈페이지기초
부트스트랩
angularjs
포럼
스크린리더
센스리더
개발자톡
개발자팁
퍼블리셔톡
퍼블리셔팁
기획자톡
기획자팁
프로그램강좌
퍼블리싱강좌
댓글 2개
http://www.phpschool.com/gnuboard4/bbs/board.php?bo_table=tipntech&wr_id=55100&page=1
http://www.phpschool.com/gnuboard4/bbs/board.php?bo_table=tipntech&wr_id=55104&page=1
그 문제는 없는건가요~?