版权声明:转载请标明出处 https://blog.csdn.net/gymaisyl/article/details/84587590
开发环境: Django:1.11
项目布局
安装 celery: pip install celery
异步任务模块 celery_tasks
;
异步任务: sms (发送短信);
config: celery异步任务的配置(这里是用来指名异步任务存储的位置);
main: 是整个异步任务的配置
在main.py
中
在 config.py配置文件中 :
broker_url = "redis://127.0.0.1/14"
注意:由于这里在定义和配置celery的时候,是已经获取了django的配置,所以可以直接使用redis://127.0.0.1/14 的具体地址,单独使用的话,需要进行相关配置的;参考: http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#broker-redis
在 tasks.py中,定义相关的任务:
参考代码:
@app.task
def add(x, y):
return x + y
运行Celery工作服务器
celery -A 项目名 worker --loglevel=info
# 简写
celery -A 项目名 worker -l info
调用异步任务
使用 任务名.delay()
即可
比如:
from tasks import add
add.delay(4, 4)