Django使用celery異步發郵件

Celery是Python開發的分布式任務調度模塊，包含以下組件：

• Celery Beat: 任務調度器，自帶的
• Celery Worker: 執行任務的消費者，通常設置多個
• Broker: 消息代理，就是任務隊列，我們使用redis
• Producer: 任務生產者，要執行的函數加上@app.task
• Result Backend: 結果保存，還是redis

Celery安裝

pip install celery[redis]   

還要安裝redis

wget http://download.redis.io/releases/redis-2.8.17.tar.gz
tar xzf redis-2.8.17.tar.gz
cd redis-2.8.17
make

#啟動
./src/redis-server redis.conf

首先實現一個最簡單的應用：

from celery import Celery

app = Celery('hello', broker='redis://localhost:6379/0')

@app.task
def hello():
    return 'hello world'

然后我們使用下面的命令啟動celery的worker：

celery -A tasks worker --loglevel=info

調度任務

>>> from tasks import add
>>> add.delay(4, 4)
>>> add.delay(4, 4).get()  #獲取結果

集成celery到django中

在項目下新建celery.py

from __future__ import absolute_import   #解決命名問題
 
import os
import django

from celery import Celery
from django.conf import settings
 
os.environ.setdefault('DJANGO_SETTINGS_MODULE','online.settings')   #設置配置文件
django.setup()
 
app = Celery('online')
 
app.config_from_object('django.conf:settings')    #制定celery配置文件
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)  #任務
app.conf.result_backend = ‘redis://localhost:6379/0’ #結果保持

settings.py配置

#配置Broker
BROKER_URL = 'redis://127.0.0.1:6379/0'
BROKER_TRANSPORT = 'redis'

郵件任務

from MxOnline.celery import app

@app.task
def send_register_email(email, send_type="register"):
    pass

異步調用

#coding:utf-8
from django.shortcuts import render
from django.http import HttpResponse

from .tasks import send_register_email

def index(request):
    send_register_email.delay()
    return HttpResponse(u"郵件發送成功， 請查收")

最后運行：

進入online工程目錄運行：
celery -A online worker -l debug    # -A 默認尋找目錄下的celery模塊

 

阿里雲

# 阿里雲封掉了25端口，這里使用SSL/465發送郵件
# 先安裝 django_smtp_ssl
pip install django_smtp_ssl

# settings 配置
EMAIL_HOST = "smtp.163.com"
EMAIL_PORT = 465
EMAIL_HOST_USER = "******@163.com"
EMAIL_HOST_PASSWORD = '******'
EMAIL_FROM = "******@163.com"
EMAIL_BACKEND = 'django_smtp_ssl.SSLEmailBackend'