使用Celery
Celery是一个专注于实时处理和任务调度的分布式队列。所谓任务就是消息,消息中的有效载荷中包含要执行任务需要的全部数据
首先,我们来看一个架构图
产生任务的方式有2种:
1、发布者发布任务(WEB应用)
2、任务调度按期发布任务(定时任务)
celery序列化:建议使用json(python使用中)
小栗子(指定队列)
celeryconfig.py配置文件:
这三个文件在名叫proj的文件夹里,现在启动进程:
celery -A proj worker -l info
指定队列的方式启动消费者进程:
celery -A proj worker -Q web_tasks -l info