django中利用celery异步发送邮件

第一步，安装celery和django-celery

第二步，celery_tasks为celery的代码位置

代码如下

from django.core.mailimport send_mail

from django.confimport settings

import time

from celeryimport Celery

import os

import django

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'dailyfresh.settings')

django.setup()

app=Celery('celery_tasks.tasks',broker='redis://127.0.0.1:6379/8')

# 定义任务函数

@app.task

def send_register_active_email(to_email, username, token):

'''发送激活邮件'''

    # 组织邮件信息

    subject ='天天生鲜欢迎信息'

    message =''

    sender = settings.EMAIL_FROM

receiver = [to_email]

html_message ='<h1>%s, 欢迎您成为天天生鲜注册会员</h1>请点击下面链接激活您的账户<br/><a href="http://127.0.0.1:8000/user/active/%s">http://127.0.0.1:8000/user/active/%s</a>' % (username, token, token)

send_mail(subject, message, sender, receiver, html_message=html_message)

time.sleep(5)

启动Django项目，在pycharm的Terminal启动celery

代码为  celery -A celery_tasks.tasks worker

会报错误

[2018-01-12 19:08:15,550: ERROR/MainProcess] Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)',) Traceback (most recent call last): File "d:\programmingsoftware\python35\lib\site-packages\billiard\pool.py", line 358, in workloop result = (True, prepare_result(fun(*args, **kwargs))) File "d:\programmingsoftware\python35\lib\site-packages\celery\app\trace.py", line 525, in _fast_trace_task tasks, accept, hostname = _loc ValueError: not enough values to unpack (expected 3, got 0)

百度得知这是win10上运行celery4.x就会出现这个问题。

需要安装：pip install eventlet

然后启动worker的时候加一个参数，如下：

celery -A <mymodule> worker -l info -P eventlet

<mymodule> 就是celery的代码位置

我的就是  celery -A celery_tasks.tasks worker -l info -P eventlet

记录一下，方便回忆