django celery 使用

上一篇 / 下一篇 2020-09-11 10:25:01 / 个人分类：Django

最近在研究分布式任务，小有收获，分享一下，采用的是django框架。

先要在django中的settings.py文件中，

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672'//默认broker是RabbitMQ,

CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']

在新建一个celery.py

在VIEW层触发celery任务。

在同一工程下，新建一个tasks.py文件，可以在里面创建需要执行的task代码，如下图

TAG: