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:

 

评分:0

我来说两句

显示全部

:loveliness: :handshake :victory: :funk: :time: :kiss: :call: :hug: :lol :'( :Q :L ;P :$ :P :o :@ :D :( :)

Open Toolbar