Hyperf异步队列日志监控与告警配置【运维】

千伟同学_4926

千伟同学_4926

2026-08-07

357人浏览

原创

必须配置独立日志通道、异常捕获与prometheus指标采集,才能实现hyperf异步队列失败告警闭环:新增async_queue日志通道并关联warning级别,手动或事件监听记录失败日志,埋点上报失败指标,通过grafana+钉钉实现5分钟失败率超20%实时告警。

hyperf异步队列日志监控与告警配置【运维】

在生产环境中,Hyperf异步队列任务失败后无声沉底、重试耗尽却无通知、积压任务无法及时发现——这些问题必须通过日志监控与告警闭环解决。

配置队列任务执行日志通道

第一步:打开 config/autoload/logger.php,在 channels 数组中新增名为 async_queue 的独立日志通道。

第二步:该通道的 handler 必须使用 RotatingFileHandler,构造参数中 filename 设为 BASE_PATH . '/runtime/logs/async-queue.log',maxFiles 设为 15,启用 compress => true。

第三步:在该通道的 processors 中加入 Hyperf\Logger\Processor\CoroutineContextProcessor::class,确保每条日志自动携带协程 ID 和请求上下文。

第四步:修改 default 通道的 handlers,将其中一条 handler 的 level 改为 Logger::WARNING,并把 channel 指向刚创建的 async_queue ——这一步不改,失败日志就进不了独立通道。

捕获并记录队列异常事件

方法一:在自定义 Job 的 handle() 方法最外层加 try-catch:

捕获所有异常后,调用 $this->logger->error('Async job failed', ['job' => get_class($this), 'params' => $this->params, 'exception' => $e->getMessage()]);【必须手动记录,否则 silent fail】

方法二:监听 Hyperf 内置事件 Hyperf\AsyncQueue\Event\AfterHandle 和 Hyperf\AsyncQueue\Event\Failed:

在 config/autoload/listeners.php 中注册监听器,对 Failed 事件强制写入 async_queue 通道,并附加 retry_count 和 fail_time 字段。

Hyperframes Creative
Hyperframes Creative

HyperFrames视频非动画创意指导,包括设计规范(frame.md/design.md)处理、配色、字体设计、旁白及节奏规划等。

下载

接入 Prometheus 实时采集队列指标

执行命令安装依赖:composer require hyperf/metric promphp/prometheus_client_php。

确认 config/autoload/metric.php 中已启用 prometheus 驱动,且 scrape_port 设置为 9502(不能与 HTTP 服务端口冲突)。

在 Job 类的 handle() 方法开头添加计数器埋点:$counter = $this->metricFactory->makeCounter('async_job_processed_total', ['status', 'job']); $counter->with('success', get_class($this))->add(1);

在 Failed 事件监听器中同步上报失败计数:$counter->with('failed', get_class($job))->add(1); —— 这是告警触发的唯一数据源。

配置 Grafana 告警看板与钉钉通知

① 登录 Grafana,在「Alerting」→「Contact points」中新建一个钉钉 contact point,填入 Webhook 地址和 secret(需提前在钉钉群机器人设置中获取)。

② 创建新告警规则,Expression 填写:rate(async_job_processed_total{status="failed"}[5m]) > 0.2,即 5 分钟内失败率超 20% 触发。

③ 在 Rule message 中插入变量:{{ $labels.job }} 连续失败 {{ $value | printf "%.1f" }} 次/分钟,当前积压 {{ (sum by(job)(rate(async_job_processed_total{status="failed"}[5m]))) | printf "%.0f" }} 条。

④ 保存后,立即点击「Test rule」验证钉钉是否收到测试消息。若未收到,检查 Hyperf 进程是否已重启以加载 metric 配置。

⑤ 手动触发一次失败任务(例如在 Job 中 throw new RuntimeException('test fail')),等待 5 分钟后确认告警是否准确推送。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
Hyperf协程并发编程实操指南
Hyperf协程并发编程实操指南

本专题深度解析 Hyperf 协程底层机制,解决协程环境下全局变量污染、Context 上下文丢失等核心痛点,提供规范化的 PHP 高并发编程实战代码建议。

2026.05.19

180

15

深入理解Hyperf AOP切面与注解使用
深入理解Hyperf AOP切面与注解使用

详尽介绍 Hyperf 依赖注入容器与 AOP 面向切面编程的使用技巧,包含自定义注解开发流程及注解不生效的排查方案,助力开发者掌握框架核心架构。

2026.05.19

444

16

Hyperf 数据库操作与连接池优化方案
Hyperf 数据库操作与连接池优化方案

针对 Hyperf Eloquent 模型在大数据量下的表现进行深度优化,讲解连接池断线重连、超时设置及事务处理等生产环境常见技术疑难。

2026.05.19

204

15

基于 Hyperf 的微服务架构集成实战
基于 Hyperf 的微服务架构集成实战

本专题涵盖 Hyperf 微服务全栈解决方案,包括服务注册与发现、配置中心集成、JsonRPC 调用以及分布式限流熔断的落地实践。

2026.05.19

256

18

Hyperf 高并发缓存与分布式系统应用
Hyperf 高并发缓存与分布式系统应用

讲解在协程模式下如何高效操作 Redis,实现高性能分布式锁、处理缓存击穿/雪崩问题,并提供基于 Hyperf 的分布式事务处理思路。

2026.05.19

448

15

Hyperf 项目部署运维与性能调优手册
Hyperf 项目部署运维与性能调优手册

聚焦 Hyperf 在生产环境的落地,包含 Docker 高效打包、Swoole 配置优化、常见的内存溢出(OOM)问题排查方法以及热更新方案。

2026.05.19

405

15

Hyperf PHP 微服务框架高性能开发实战
Hyperf PHP 微服务框架高性能开发实战

本专题围绕 Hyperf 框架展开,讲解微服务架构设计、协程异步处理、服务注册与发现、RPC 通信及性能优化策略。通过完整项目示例,帮助开发者构建高效、稳定、可扩展的 PHP 分布式服务系统。

2026.06.08

196

23

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

2026.09.30

80

10

LLVM RISC-V参数配置教程
LLVM RISC-V参数配置教程

本专题介绍LLVM对RISC-V基础ISA和扩展的支持方式,涵盖RV32、RV64、标准扩展、实验性扩展、厂商扩展、-menable-experimental-extensions和版本差异。

2026.09.30

80

14

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Hyperf官方中文手册(3.1)
Hyperf官方中文手册(3.1)

共0课时 | 0人学习

Swoole系列-从0到1-新手进阶
Swoole系列-从0到1-新手进阶

共29课时 | 2.3万人学习