📦 Celery Task Analyzer — Celery 任务分析器

Celery Task Analyzer 分析 Celery 任务配置，保障可靠性、性能与运维卓越。审查任务定义、重试策略、路由规则、序列化设置、结果后端配置、Worker 调优及 Beat 调度。扮演资深分布式系统工程师，审计你的 Celery 部署。

用法 需要审查 Celery 任务配置、优化 Worker 性能或确保可靠性最佳实践时调用本技能。

基础调用

• 分析 /path/to/app/tasks/ 中的 Celery 任务
• 审查该 Celery 配置是否具备生产就绪性
• 检查项目内任务可靠性

专项分析

• 审计所有 Celery 任务的重试策略
• 审查任务路由配置
• 检查 Beat 调度是否存在重叠任务
• 分析 Worker 配置是否内存泄漏

Agent 读取 Celery 任务文件、配置模块与 Beat 调度，生成全面质量报告。

工作原理 Step 1：发现与解析 Celery 组件 Agent 定位所有 Celery 相关代码：

# 查找 Celery app 配置
grep -rl "Celery(\|celery_app\|make_celery" /path/to/app/ --include=".py"
# 查找任务定义
grep -rl "@app.task\|@shared_task\|@celery.task" /path/to/app/ --include=".py"
# 查找 Beat 调度定义
grep -rl "beat_schedule\|CELERYBEAT_SCHEDULE\|crontab\|solar" /path/to/app/ --include=".py"
# 查找配置文件
grep -rl "broker_url\|result_backend\|CELERY_" /path/to/app/ --include=".py"

解析并提取：

• App 配置（broker、backend、序列化、时区）
• 任务定义（名称、模块、装饰器、参数）
• 重试策略（max_retries、retry_backoff、retry_jitter）
• 路由规则（queues、exchanges、routing keys）
• Beat 调度（周期任务、crontab、intervals）
• 信号处理器（task_prerun、task_postrun、task_failure）
• Worker 配置（concurrency、prefetch、pool type）

Step 2：审计任务定义 检查每项任务配置：

• 装饰器分析
• 命名审计

Step 3：分析重试策略 评估重试配置可靠性。