当前位置: 首页 > news >正文

Celery inspect 常用命令手册

📘 Celery Inspect 常用命令清单 & 字段解释

运行格式:

 
celery -A <app_name> inspect <command>

1. active

含义

显示 正在执行的任务(worker 正在跑的任务)。

示例

 
{ "worker1@host": [ { "id": "f5e9b8c7-1234-5678-90ab-abcdef123456", "name": "tasks.add", "args": "(2, 3)", "kwargs": "{}", "time_start": 1694501234, "worker_pid": 12345 } ] }

字段解释

字段含义
id 任务 ID
name 任务函数名
args 位置参数
kwargs 关键字参数
time_start 开始执行时间(Unix 时间戳)
worker_pid worker 子进程 PID

2. reserved

含义

显示 已分配到 worker 但尚未执行的任务(在本地等待队列里)。

示例

 
{ "worker1@host": [ { "id": "a1b2c3d4-5678-90ab-cdef-1234567890ab", "name": "tasks.send_email", "args": "('user@example.com',)", "kwargs": "{}" } ] }

字段解释

字段含义
id 任务 ID
name 任务函数名
args 位置参数
kwargs 关键字参数

3. scheduled

含义

显示 已调度但未到期执行的任务(ETA 或 countdown 的任务)。

示例

 
{ "worker1@host": [ { "eta": "2025-09-15T10:30:00Z", "priority": 0, "request": { "id": "abc123", "name": "tasks.cleanup", "args": "()", "kwargs": "{}" } } ] }

字段解释

字段含义
eta 预计执行时间
priority 任务优先级
request 任务详情(id、name、args、kwargs)

4. stats

含义

显示 worker 的运行状态和统计信息

示例

 
{ "worker1@host": { "pool": { "max-concurrency": 8, "processes": [12345, 12346], "max-tasks-per-child": "N/A" }, "broker": { "transport": "redis", "connected": true }, "tasks": { "tasks.add": { "total": 120, "failures": 2, "retries": 5 } }, "uptime": 3600, "hostname": "worker1@host" } }

字段解释

字段含义
pool.max-concurrency 最大并发数
pool.processes worker 子进程 PID 列表
pool.max-tasks-per-child 每个子进程执行的最大任务数
broker.transport broker 类型(redis/rabbitmq)
broker.connected 是否已连接
tasks 各任务累计执行统计(total/failures/retries)
uptime worker 运行时间(秒)
hostname worker 名称

5. registered

含义

显示 worker 注册的任务(即 worker 能执行哪些任务函数)。

示例

 
{ "worker1@host": [ "tasks.add", "tasks.send_email" ] }

6. active_queues

含义

显示 worker 监听的队列信息

示例

 
{ "worker1@host": [ { "name": "celery", "exchange": "celery", "routing_key": "celery" } ] }

字段解释

字段含义
name 队列名
exchange 交换机
routing_key 路由键

7. ping

含义

检查 worker 是否存活。

示例

 
{ "worker1@host": "pong" }

8. report

含义

输出 worker 的详细报告(配置、版本、环境信息)。
通常用于调试。


📊 命令对比表

命令作用输出内容
active 当前正在执行的任务 任务 id、函数名、参数、开始时间、PID
reserved 等待执行的任务(已取出未执行) 任务 id、函数名、参数
scheduled 定时/延迟任务 ETA、优先级、任务详情
stats Worker 运行统计信息 pool、broker、任务计数、uptime
registered 注册的任务函数 任务名列表
active_queues 监听的队列 队列名、exchange、routing_key
ping 检查存活 pong
report 详细环境和配置 Worker 报告

要不要我帮你再整理一个 故障排查场景对应用哪个 inspect 命令 的对照表?这样一看就知道该查哪个命令。

http://www.wxhsa.cn/company.asp?id=4475

相关文章:

  • 都可以!燕千云ITSM一站式接入全球主流AI大模型
  • 删边最短路
  • 问题解决模板
  • 一站式接入全球股票数据:日本、美国、印度、马来西亚等多国API对接实战
  • 基于MATLAB的图像处理程序
  • 跨网文件安全交换系统推荐厂商详解
  • 走迷宫
  • MVC 架构解析
  • 鸿蒙应用开发从入门到实战(五):ArkUI概述
  • 好用的跨网文件安全交换系统:守护企业数据流转的核心屏障!
  • SIM笔记
  • 2025第五届“长城杯”网络安全大赛暨京津冀蒙网络安全技能竞赛 WP Web全
  • FTP替代工具哪个产品好,高效安全之选
  • c++之内存对齐模板类aligned_storage
  • ABC 423先慢慢改吧题解
  • 汇聚层交换机的替换要考虑到的因素
  • git 常见使用
  • python UV 包管理工具安装
  • 什么是网络分区
  • 完整教程:《驾驭云原生复杂性:隐性Bug的全链路防御体系构建》
  • 从机器的角度来说ECS为何性能好
  • 人生最幸福的时刻也就几个瞬间
  • 网络流笔记
  • 实用指南:经典动态规划题解
  • 2025杭电多校(2)
  • latex 打印生僻字
  • CSP-S 2025 游记(The Last CSP ver.)
  • 电机ADC采集
  • 道德经
  • TokenFlow: Unified Image Tokenizer for Multimodal Understanding and Generation - jack