Celery 速查
共 25 条 Celery 速查：定义与调用、运行与调度、监控与运维、进阶、生产实践。 支持搜索与分类筛选，点击即可复制。
定义与调用
Python 最常用异步任务队列。
| 命令 | 说明 |
|---|---|
| 创建应用与 broker | |
| 定义任务 | |
| 异步调用（发到队列） | |
| 延迟 10 秒执行 | |
| 取结果（需 result backend） |
运行与调度
worker 与 beat。
| 命令 | 说明 |
|---|---|
| 启动 worker | |
| 并发 4、监听多个队列 | |
| 启动定时调度器 | |
| 定时配置 | |
| 自动伸缩 |
监控与运维
查看与控制任务。
| 命令 | 说明 |
|---|---|
| 启动 Flower 图形监控 | |
| 查看活动 / 已注册任务 | |
| 统计 / 存活检查 | |
| 清空队列（谨慎） | |
| 查看 worker 状态 |
进阶
编排与路由。
| 命令 | 说明 |
|---|---|
| 串行工作流 | |
| 并行 | |
| 并行后回调 | |
| 任务路由 | |
| 重试 | |
| broker 与结果后端 |
生产实践
可靠性与部署。
| 命令 | 说明 |
|---|---|
| 提高可靠性 | |
| 公平分发 | |
| 进程管理 | |
| 组件选型 |
使用说明
Celery 速查：定义与调用、运行与调度、监控与运维、进阶、生产实践；支持搜索与分类筛选，点击即可复制。
- 按用途点分类：定义与调用、运行与调度、监控与运维、进阶、生产实践。
- 点「命令」列复制到 Python 代码或终端。
- 耗时任务放 Celery，Web 进程只负责入队（delay）。
- 定时任务交给 beat；监控用 flower 或 inspect。
常见问题
- 任务会不会重复执行？
- 默认可能（worker 崩溃且未确认时）。需要至少一次语义时用 acks_late 并让任务幂等；需要精确一次较难，需业务去重。
- broker 用 Redis 还是 RabbitMQ？
- RabbitMQ 的确认与路由更可靠、适合复杂场景；Redis 部署简单、够用。按可靠性要求选择。
- 需要联网吗？
- 速查内容本地可用；运行需 broker。
延伸阅读
相关工具
TRN
Trino 速查
SHOW CATALOGS / EXCLUDE / catalog 速查
DBT
dbt 速查
dbt run / ref / materialized / test 速查
SNW
Snowflake 速查
WAREHOUSE / QUALIFY / COPY INTO / Time Travel 速查
BQ
BigQuery 速查
bq query / UNNEST / PARTITION BY / dry_run 速查
ZK
ZooKeeper 速查
zkServer / zkCli / 四字命令速查
NMD
Nomad 速查
nomad job run / HCL / alloc logs 速查