<?php // routes/web.php

Route::get('/', function () {
    $message = "Hello Monolog";
    $context = ['foo' => 'bar'];
    
    Log::emergency($message, $context);
    Log::alert($message);
    Log::critical($message);
    Log::error($message);
    Log::warning($message);
    Log::notice($message);
    Log::info($message);
    Log::debug($message);
    
    return view('welcome');
});

<?php // routes/web.php 

use Elasticsearch\ClientBuilder;

Route::get('/', function () {
    $esClient = ClientBuilder::create()->build();
    dd($esClient);
});

<?php // app/Providers/CustomLogProvider.php

namespace App\Providers;

use App\LogHandlers\ESHandler;
use Elasticsearch\ClientBuilder;
use Illuminate\Support\ServiceProvider;
use Monolog\Formatter\NormalizerFormatter;
use Monolog\Processor\WebProcessor;

class CustomLogProvider extends ServiceProvider
{
    public function boot()
    {
        // 라라벨이 부팅하면서 서비스 컨테이너에 이미 등록해놓은 Monolog 인스턴스를 가져온다.
        $monolog = $this->app['log']->getMonolog();
        
        // Elastic Search REST 클라이언트 인스턴스를 만든다.
        $esClient = ClientBuilder::create()->build();
        
        // Monolog에 추가할 Elastic Search 핸들러 인스턴스를 만든다.
        $esHandler = new ESHandler($esClient);
        
        // NormalizerFormatter는 라이브러리에 내장되어 있다.
        // Monolog 메서드의 인자인 $message, $context 값을 정규화한다.
        // 정규화란 데이터 타입을 판단하고 적졀한 형태로 가공하는 것을 말한다.
        $esHandler->setFormatter(new NormalizerFormatter('Y-m-d\TH:i:s.uP'));
        
        // WebProcessor는 HTTP 요청에서 url, ip, http_method, referrer 등의 
        // 값을 추출하고 로그 메시지에 추가하는 일을 한다.
        $esHandler->pushProcessor(new WebProcessor);
        
        // Monolog 라이브러리에 기본 포함된 프로세서가 아닌 정말 정말 커스컴 프로세서를 추가해서
        // 로깅할 데이터를 더 추가한다. 여기서는 애플리케이션 이름, 버전, HTTP 요청을 구분할 수 있는 Hash 값을 추가했다.
        $esHandler->pushProcessor(function (array $record) {
            $record['extra']['app_name'] = config('app.name');
            $record['extra']['app_version'] = env('APP_VERSION', -1);
            $record['extra']['fingerprint'] = request()->fingerprint();
            return $record;
        });
        
        // Elastic Search 핸들러를 Monolog에 추가했다.
        // Monolog는 핸들러를 쌓아 두었다가, 하나씩 순차적으로 실행한다.
        // 즉, 라라벨이 기본으로 생성한 StreamHanlder(파일 로그)를 실행하고, 방금 만든 ESHandler도 실행한다.
        // 이미 생성된 인스턴스의 속성을 변경하는 것이므로 return할 필요 없다.
        $monolog->pushHandler($esHandler);
    }
}

<?php // app/LogHandlers/ESHandler.php

namespace App\LogHandlers;

use Elasticsearch\Client as ESClient;
use Monolog\Handler\AbstractProcessingHandler;
use Monolog\Logger;

class ESHandler extends AbstractProcessingHandler
{
    private $esClient;

    public function __construct(ESClient $esClient, $level = Logger::DEBUG, $bubble = true)
    {
        parent::__construct($level, $bubble);

        $this->esClient = $esClient;
    }

    protected function write(array $record = [])
    {
        $payload = [
            'refresh' => true,
            'body' => [
                [
                    'index' => [
                        '_index' => 'monolog',
                        '_type' => config('app.name')
                    ]
                ],
                $record['formatted'],
            ]
        ];

        $this->esClient->bulk($payload);
    }
}

<?php // config/app.php

return [
    // ...
    'providers' => [
        // ...
        App\Providers\CustomLogProvider::class,
    ]
]

<?php // web/routes.php

Route::get('/', function () {
    $message = "Hello Monolog";
    $context = ['foo' => 'bar'];
    Log::debug($message, $context);
    
    return view('welcome');
});

<?php // app/Providers/CustomLogProvider.php

class CustomLogProvider extends ServiceProvider
{
    public function boot()
    {
        // ...
        $errorLogHandler = new \Monolog\Handler\ErrorLogHandler();
        $monolog->pushHandler($errorLogHandler);
    }
}