参考资料:celery官方教程
Demo
给网站做了一个留言板，留言后直接发送邮件给管理员，顺便加上celery测试了一下异步任务。celery基本按照官方教程来就可以，仅有setting.py要注意一下。
- 用163发送邮件设置比较方便，一般不会有什么问题，注意from_email必须填真实的，否则550错误，需要去邮箱设置开通smtp发送权限，本地服务器直接发送容易遇到各种问题，建议用smtp
- 使用django发送邮件之前，先在服务器环境下测试，看能否发送邮件，可能需要
apt-get install sendmailcelery -A proj worker -l info查看celery tasks状态，见下图MainProcess ] Received task是收到任务，PoolWorker-1] Task是执行任务
Paste_Image.png
settings.py
Email配置
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
EMAIL_HOST_USER = 'youemailname@163.com'
EMAIL_HOST_PASSWORD = 'pass'
EMAIL_USE_TLS = False
DEFAULT_FROM_EMAIL = 'Server <sever@xxx.com>'
celery部分配置参考的是celery官方的django demo
# CELERY_BROKER_URL = 'amqp://guest:guest@localhost//'
# 不用amqp后端，我自己换成redis #/0为redis第一个数据库
CELERY_BROKER_URL = 'redis://localhost:6379/0'
#这两个json应该也可以不用，使用默认就行，还不知道有什么区别，以后再研究
CELERY_ACCEPT_CONTENT = ['json']
# 这个也不要了
# CELERY_RESULT_BACKEND = 'db+sqlite:///results.sqlite'
CELERY_TASK_SERIALIZER = 'json'
代码部分
邮件发送代码
@shared_task
def levemessage(message):
time.sleep(60)
send_mail(subject='网站有一个留言',message=message,from_email='youremail@163.com',recipient_list=['yourotheremail@qq.com'],fail_silently=False)
print('mail sent')
django.views留言代码
def contactme(request):
email = request.GET.get('email')
message = request.GET.get('message')
print('email:',email,'message:',message)
if not (email and message):
return render(request,'page/contactme.html')
else:
print('sendemail')
content = 'email:%s\nmessage:%s\n' %(email,message)
levemessage.delay(content)
return HttpResponse('留言成功,谢谢反馈')
html模板
{% block content %}
<div class="contactform">
<label for="email">Email</label><input type="text" name="email" id="email">
<label for="message">留言</label><textarea name="message" id="message" cols="30" rows="6"></textarea>
<button id="contactme">提交留言</button>
</div>
{% endblock %}
ajax提交
<script>
function contactme(data) {
var xhr = new XMLHttpRequest();
xhr.onreadystatechange = function() {
if(xhr.readyState === 4) {
if (xhr.status === 200) {
alert('成功发送留言,点击确定后跳转到首页');
window.location.href = "/";
} else {
alert('留言失败，网络或者系统出现故障')
}
}
}
xhr.open('GET','/contact_me.html?'+data);
xhr.send(data);
alert('请求已发送，请等待响应');
}
var i = function initElem() {
var message = document.getElementById('message').value;
var email = document.getElementById('email').value;
params = "email="+ encodeURIComponent(email) + "&message=" + encodeURIComponent(message);
contactme(params);
}
var btn = document.getElementById('contactme');
btn.onclick = i;
</script>
