celery

celery
性能優化的工具。
django是單進程的，celery可以在django框架內部開闢開啓一個新進程，用來處理耗時的工做。
這樣的好處是，用戶能夠快速得到響應。

celery的4個概念
任務task：就是一個Python函數
隊列queue：將須要執行的任務加入到隊列中
工人worker：在一個新進程中，負責執行隊列中的任務
代理人broker：負責調度，在佈置環境中使用redis。相似車間的隊長，安排任務分配給工人幹。

celery官方文檔
中文：http://docs.jinkan.org/docs/celery/

何時用celery
一、耗時
二、和響應結果不要緊

安裝包
celery==3.1.25
celery-with-redis==3.0
django-celery==3.1.17

 

 

示例

• 在tt_user/views.py文件中建立視圖sayhello

import time
...
def sayhello(request):
    print('hello ...')
    time.sleep(2)
    print('world ...')
    return HttpResponse("hello world")

• 在tt_user/urls.py中配置

url(r'^sayhello$',views.sayhello),

• 啓動服務器，在瀏覽器中輸入以下網址

http://127.0.0.1:8000/sayhello/

• 在終端中效果以下圖，兩次輸出之間等待一段時間纔會返回結果

 

• 在settings.py中安裝

INSTALLED_APPS = (
  ...
  'djcelery',
}

• 在settings.py文件中配置代理和任務模塊

import djcelery
djcelery.setup_loader()
BROKER_URL = 'redis://127.0.0.1:6379/2'
CELERY_IMPORTS = ('booktest.task')

• 在tt_user目錄下建立task.py文件

import time
from celery import task

@task
def sayhello():
    print('hello ...')
    time.sleep(2)
    print('world ...')

• 打開tt_user/views.py文件，修改sayhello視圖以下

from . import task
...
def sayhello(request):
    # print('hello ...')
    # time.sleep(2)
    # print('world ...')
    task.sayhello.delay()
    return HttpResponse("hello world")

• 執行遷移生成celery須要的數據表

python manage.py migrate

• 生成表以下

 

 

• 啓動Redis，若是已經啓動則不須要啓動

sudo service redis start

• 啓動worker

python manage.py celery worker --loglevel=info

• 啓動成功後提示以下圖

 

 

 

• 打開新終端，進入虛擬環境，啓動服務器，刷新瀏覽器
• 在舊終端中兩個輸出間仍有時間間隔

 

 

 

• 運行完成後以下圖，注意兩個終端中的時間，服務器的響應是當即返回的

 

 

• 打開tt_user/task.py文件，修改成發送郵件的代碼，就能夠實現無阻塞發送郵件

#coding=utf-8
from django.conf import settings
from django.core.mail import send_mail
from celery import task

@task
def sayhello():
    msg='<a href="http://127.0.0.1/user/active/" target="_blank">點擊激活</a>'
    send_mail('註冊激活','',settings.EMAIL_FROM,
              ['itcast88@163.com'],
              html_message=msg)