apache_log.php

<?php
require __DIR__ . '/vendor/autoload.php';
function getLogInfo($str)
{
    $str = trim($str);
    $i   = strpos($str, '"');
    if ($i === false) {
        return [[], $str];
    }
    $arr = explode(' ', substr($str, 0, $i));
    return [$arr, substr($str, $i + 1)];
}

function array_get($arr, $k, $d = null)
{
    return isset($arr[$k]) ? $arr[$k] : $d;
}

// LogFormat "%{Host}i %{X-Forwarded-For}i-%h %{ms}T %t \"%r\" %>s %b \"%{Referer}i\" \"%{User-Agent}i\"" combined
function get_row($str)
{
    $data = [
        'host'        => '',
        'ip'          => '0.0.0.0',
        'duration'    => null,
        'create_time' => null,
        'method'      => 'no',
        'url'         => '',
        'path'        => '',
        'code'        => '',
        'size'        => '',
        'refer'       => '',
        'refer_host'  => '',
        'user_agent'  => ''
    ];
    list($arr, $str) = getLogInfo($str);
    $data['host'] = array_get($arr, 0);
    $data['ip']   = array_get($arr, 1);
    if (strpos($data['ip'], '--') === 0) {
        $data['ip'] = substr($data['ip'], 2);
    } else {
        $i = strpos($data['ip'], ',');
        if ($i !== false) {
            $data['ip'] = substr($data['ip'], 0, $i);
        } else {
            $data['ip'] = substr($data['ip'], 0, strpos($data['ip'], '-'));
        }
    }
    $data['duration']    = array_get($arr, 2);
    $t                   = trim(array_get($arr, 3, ''), '[ ') . ' ' . trim(array_get($arr, 4), ' ]');
    $data['create_time'] = date('Y-m-d H:i:s', strtotime($t));

    list($arr, $str) = getLogInfo($str);
    $data['method'] = trim(array_get($arr, 0));
    $data['url']    = trim(array_get($arr, 1));
    $ur             = parse_url($data['url']);
    $data['path']   = $ur['path'];

    $i = stripos($data['path'], '.');
    if ($i) {
        $ext  = substr($data['path'], $i + 1);
        $exts = [
            'css' => 1,
            'js'  => 1,
            'txt' => 1,
            'png' => 1,
            'jpg' => 1,
            'gif' => 1
        ];
        if (isset($exts[$ext])) {
            return false;
        }
    }

    list($arr, $str) = getLogInfo($str);
    $data['code'] = trim(array_get($arr, 0));
    $data['size'] = trim(array_get($arr, 1));

    list($arr, $str) = getLogInfo($str);
    $data['refer'] = isset($arr[0]) ? trim($arr[0]) : '';
    if ($data['refer']) {
        $ur                 = parse_url($data['refer']);
        $data['refer_host'] = isset($ur['host']) ? $ur['host'] : '';
        $data['user_agent'] = trim($str, ' "');
    }
    foreach ($data as $k => $val) {
        if ($val === null) {
            return false;
        }
    }
    return $data;
}

//$v = get_row($str);

$table = getopt('h:u:p:d:t:s:');

if (!isset($table['t'])) {
    exit("请设置表名 -t tableName \n");
}

if (!isset($table['s'])) {
    $table['s'] = 'default';
}

$ck = new Log2Ck($table['t'], ['host', 'ip', 'duration', 'create_time', 'method', 'url', 'path', 'code', 'size', 'refer', 'refer_host', 'user_agent', 'server_name']);
$ck->regLogFn(function ($str) use ($table) {
    $arr = get_row($str);
    if ($arr) {
        $arr['server_name'] = $table['s'];
    }
    return $arr;
})->run();