Django中通过celery完成异步任务

￡神魔★判官ぃ 2022-04-13 08:51 199阅读 0赞

开发环境： Django：1.11

## 项目布局 ##

安装 celery： `pip install celery`

--------------------

异步任务模块 `celery_tasks`;  
异步任务： sms (发送短信)；  
config： celery异步任务的配置（这里是用来指名异步任务存储的位置）；  
main： 是整个异步任务的配置  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d5bWFpc3ls_size_16_color_FFFFFF_t_70]

**在`main.py`中**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d5bWFpc3ls_size_16_color_FFFFFF_t_70 1]

**在 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][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)

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d5bWFpc3ls_size_16_color_FFFFFF_t_70]: /images/20220413/3f5150b8fb2b49a38eceaae3adbf2cfd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d5bWFpc3ls_size_16_color_FFFFFF_t_70 1]: /images/20220413/cc69b5fd74c64cad9eed156644b7f660.png
[http_docs.celeryproject.org_en_latest_getting-started_brokers_redis.html_broker-redis]: http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#broker-redis