Laravel怎么处理队列任务执行日志结构化输出_Laravel便于ELK日志分析【操作】-Laravel-PHP中文网

laravel队列日志需每行输出合法json且字段名固定，启用'json'=>true配置，通过jobprocessed/jobfailed事件统一注入上下文，避免自由文本和大对象，logstash中用json filter配合remove_field和date filter，并用tail+pq本地验证结构。

laravel怎么处理队列任务执行日志结构化输出_laravel便于elk日志分析【操作】

队列任务日志怎么打才能被ELK自动解析

默认的 Laravel 队列日志是纯文本，json_decode 会失败，Logstash 的 json 过滤器直接跳过——根本进不了 Elasticsearch。必须让每条日志本身是一行合法 JSON，且字段名固定、类型稳定。

别用 Log::info('task started') 这类自由文本，它无法被结构化提取
改用 Log::channel('stack')->info('queue job executed', [...])，第二个参数传关联数组，Laravel 会自动转成 JSON 字段（前提是日志驱动是 single 或 daily 且 json 设为 true）
确保 config/logging.php 中对应 channel 的 'json' => true 已启用，否则即使传了数组，输出仍是 key=value 格式
字段名避免空格、点号、斜杠，比如用 job_name 而非 job.name，否则 Logstash 的 grok 或 dissect 容易出错

Laravel 队列监听时如何注入统一上下文

单个任务里硬编码 Log::info(..., ['job_id' => $job->jobId()]) 不现实——你得在每个 handle() 开头手动加，漏一个就断链。真正可行的是利用 Laravel 的 JobProcessed 和 JobFailed 事件，全局拦截。

在 App\Providers\EventServiceProvider 的 $listen 中注册：Illuminate\Queue\Events\JobProcessed::class => [App\Listeners\LogQueueExecution::class]
LogQueueExecution 的 handle() 方法里调用 Log::channel('queue_json')->info('job processed', [...])，把 $event->job->resolveName()、$event->job->attempts()、耗时等全塞进去
注意：不要在监听器里抛异常，否则可能干扰队列重试逻辑；如需记录失败，单独监听 JobFailed 事件
避免在日志中写入大对象（如整个 $job->data），容易撑爆 ES 字段长度限制（默认 text 类型是 32766 字节）

logstash 配置里最常踩的 JSON 解析坑

很多人配了 json { source => "message" } 却发现字段没展开，其实是因为日志文件里混了非 JSON 行（比如 PHP warning、Symfony debug header），Logstash 一遇到解析失败就整条丢弃。

Laravel Creem Agent

Creem 支付商店助理 — 查询订阅、客户、交易、产品，执行心跳检查，管理本地 Laravel支付商店。

下载

先用 filebeat 做预过滤：在 filebeat.inputs 中加 exclude_lines: ['^\s*$', '^\[.*\].*']，跳过空行和非 JSON 开头的调试行
Logstash 的 json filter 必须配合 remove_field => ["message"]，否则原始字符串还在，Kibana 里会看到重复字段
如果日志里有嵌套 JSON 字符串（比如 "payload": "{\"user_id\":123}"），默认 json filter 不会递归解析，得用 mutate + json_decode 二次处理
时间戳字段名必须是 @timestamp，否则 Kibana 时间范围筛选失效；Laravel 默认用 datetime，要在 Logstash 里用 date filter 显式映射

本地开发时怎么快速验证日志结构是否合格

别等部署到 ELK 环境才发现字段对不上——用 tail -f + jq 就能秒级验证。

运行 php artisan queue:work --verbose，同时开另一个终端：tail -f storage/logs/laravel.log | jq -r '.job_name // .message'
如果报 parse error，说明某行不是合法 JSON；如果输出 null，说明字段名不对或被嵌套了
检查关键字段是否存在：tail -f storage/logs/laravel.log | jq 'has("job_name") and has("duration_ms") and has("@timestamp")'
注意：本地 APP_ENV=local 时，日志可能走 stack channel 并包含多行堆栈，务必切到 APP_ENV=production 测试，否则结构不一致