所有演示均基于Django2.0

celery是一個基于python開發的簡單、靈活且可靠的分布式任務隊列框架，支持使用任務隊列的方式在分布式的機器/進程/線程上執行任務調度。采用典型的生產者-消費者模型，主要由三部分組成：

異步任務

我的異步使用場景為項目上線：前端web上有個上線按鈕，點擊按鈕后發請求給后端，后端執行上線過程要5分鐘，后端在接收到請求后把任務放入隊列異步執行，同時馬上返回給前端一個任務執行中的結果。若果沒有異步執行會怎么樣呢？同步的情況就是執行過程中前端一直在等后端返回結果，頁面轉呀轉的就轉超時了。

異步任務配置

1.安裝rabbitmq，這里我們使用rabbitmq作為broker，安裝完成后默認啟動了，也不需要其他任何配置

# apt-get install rabbitmq-server

2.安裝celery

# pip3 install celery

3.celery用在django項目中，django項目目錄結構(簡化)如下

website/|-- deploy|  |-- admin.py|  |-- apps.py|  |-- __init__.py|  |-- models.py|  |-- tasks.py|  |-- tests.py|  |-- urls.py|  `-- views.py|-- manage.py|-- README`-- website  |-- celery.py  |-- __init__.py  |-- settings.py  |-- urls.py  `-- wsgi.py

4.創建 website/celery.py 主文件

from __future__ import absolute_import, unicode_literalsimport osfrom celery import Celery, platforms# set the default Django settings module for the 'celery' program.os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'website.settings')app = Celery('website')# Using a string here means the worker don't have to serialize# the configuration object to child processes.# - namespace='CELERY' means all celery-related configuration keys#  should have a `CELERY_` prefix.app.config_from_object('django.conf:settings', namespace='CELERY')# Load task modules from all registered Django app configs.app.autodiscover_tasks()# 允許root 用戶運行celeryplatforms.C_FORCE_ROOT = True@app.task(bind=True)def debug_task(self):  print('Request: {0!r}'.format(self.request))

5.在 website/__init__.py 文件中增加如下內容，確保django啟動的時候這個app能夠被加載到

from __future__ import absolute_import# This will make sure the app is always imported when# Django starts so that shared_task will use this app.from .celery import app as celery_app__all__ = ['celery_app']