ryanisnan/rq-queue-checker

概述

rq-queue-checker是一个简单的容器，用于检查Python RQ异步队列系统中的队列状态，并向Slack发送警报。它设计为单次运行，因此最适合通过cron定时任务或lambda函数执行。该项目可在Docker Hub获取：ryanisnan/rq-queue-checker

核心功能

• 检查指定Python RQ队列的长度是否超过预设阈值
• 当队列长度超过阈值时，通过Slack webhook发送警报通知
• 支持配置Redis服务器连接信息和队列阈值
• 可调整日志输出级别

使用场景

• 监控RQ队列是否出现任务积压，及时通知团队处理
• 适用于使用Python RQ作为异步任务队列的后端服务
• 需要定时检查队列状态的场景

配置说明

容器支持以下环境变量配置：

• REDIS_HOST：Redis服务器的主机名
• REDIS_PORT：Redis服务器的端口
• QUEUE_CONFIG：字符串化的JSON对象，包含队列名称与对应阈值的键值对，例如{"high":1000,"default":2000}
• SLACK_WEBHOOK_URL：用于发送Slack频道消息的webhook地址
• LOGLEVEL：日志输出级别，默认值为10（Debug），对应Python日志级别

运行测试

bash
git clone git@github.com:ryanisnan/rq-queue-checker
cd rq-queue-checker
docker-compose -f docker-compose.test.yml up --build --exit-code-from queue_checker

本地运行示例

bash
docker run \
  -e REDIS_HOST=redis.example.com \
  -e REDIS_PORT=6379 \
  -e QUEUE_CONFIG='{"high":1000,"default":2000}' \
  -e SLACK_WEBHOOK_URL=https://hooks.slack.com/services/your-webhook-path \
  ryanisnan/rq-queue-checker

贡献指南

请确保您的贡献包含测试用例，并提交Pull Request。