用途:为 Celery 异步任务开发提供可直接套用的生产级模板与模式,覆盖错误处理、重试、限流、超时与自定义任务类等常见需求。
主要能力:包含八类模板——基础任务、重试任务(autoretry_for、指数退避与抖动)、限流任务(每秒/分/时限制)、时间限制任务(软超时与硬超时)、自定义任务基类(连接池、结果缓存、指标、生命周期钩子)、Pydantic 输入校验、数据库任务(参数化查询、事务、批量插入、分页)以及外部 API 任务(认证、分页、批量、超时)。
使用方式:通过脚本生成任务,如 ./scripts/generate-task.sh retry-task tasks/my_api_call.py fetch_data;用 ./scripts/test-task.sh <task_file.py> [task_name] 做语法、导入、结构与安全检查;用 ./scripts/validate-task.sh <task_file.py> 做完整校验。任务以 celery -A tasks worker --loglevel=info 启动 worker 执行。
适用场景:调用易失败的外部 API、数据库操作、需要控制执行速度或防止任务挂起的场景,以及需要统一校验与监控的任务。
限制:资料未提供具体依赖版本、安装命令、性能数据或收费信息;模板中的凭据均以占位符和环境变量形式给出,需自行配置。