🗒️Flask中Celery的使用
type
status
slug
summary
tags
category
icon
password
Date
Celery是一个用于处理异步任务和消息队列的库,主要优势在于能够处理耗时的、计算密集型或者需要异步执行的任务
术语
任务生产者:调用Celery提供的API、函数、装饰器产生任务并交给任务队列的都是任务生产者。
执行单元worker:属于任务队列的消费者,持续地监控任务队列,当队列中有新的任务时,便取出来执行。
任务结果存储backend:用来存储worker执行任务的结果,Celery支持不同的方式存储任务的结果,包括AMQP、Redis、memcached、MongoDB、SQLAlchemy等
任务调度器Beat:Beat进程会读取配置文件的内容,周期性地将配置中到期需要执行的任务发送给任务队列。

最简单的示例
app.py
实际应用中的示例
app/__init__.py
app/utils/celery_util.py
app/factory.py
app/tasks/add.py
views/add.py
runcelery.py
bash
Loading...