用途:为后台任务处理提供可落地的工程约定,涵盖 Celery、ARQ、Redis 与 Temporal。它是一个包装层而非产品手册,只保留团队自有增量:阈值、可用配置、顺序约束与工具选型规则,产品机制以链接方式给出。
主要能力:配置(序列化用 JSON、late ack、预取大小、软硬超时、UTC);任务路由(五级队列 critical/high/default/low/bulk、0-9 优先级、每队列独立 worker);Canvas 工作流(chain/group/chord、si() 不可变签名、chord 头部返回错误字典);重试策略(指数退避加抖动、上限 600 秒、幂等标记与厂商幂等键、DLQ);调度(crontab 与 float interval、DatabaseScheduler、Redis 锁防重叠、beat 独立进程);监控(Flower、Prometheus 指标、队列深度告警阈值);结果后端(Redis 存状态与小 JSON、大结果存 S3 或数据库并返回引用、update_state() 自定义进度);ARQ 模式(原生异步、max_jobs=10、job_timeout=300、连接池由 FastAPI lifespan 管理);Temporal 的 Workflow 与 Activity 规则。
使用方式:先读 references/ork-delta.md,再按主题读对应 rules 或 references 文件,例如 rules/celery-canvas.md、rules/jobs-scheduling.md、references/quick-start-examples.md。示例任务使用 @app.task(bind=True, max_retries=3, default_retry_delay=60) 与 self.retry(exc=exc, countdown=2 ** self.request.retries * 60)。
适用场景:Python 后端异步任务、定时调度、分布式工作流与 LLM 之外的批处理流程。LLM 工作流建议用 LangGraph 而非 Celery。
限制:canvas 中 si()-in-chords 的传参行为标注为 UNVERIFIED 且有争议,需对照上游文档确认;上游产品机制不在此复述;未提供收费、价格、平台或效果信息。