django自动发送邮件 + celery使用

参考资料:celery官方教程
Demo
给网站做了一个留言板，留言后直接发送邮件给管理员，顺便加上celery测试了一下异步任务。celery基本按照官方教程来就可以，仅有setting.py要注意一下。

1. 用163发送邮件设置比较方便，一般不会有什么问题，注意from_email必须填真实的，否则550错误，需要去邮箱设置开通smtp发送权限，本地服务器直接发送容易遇到各种问题，建议用smtp
2. 使用django发送邮件之前，先在服务器环境下测试，看能否发送邮件，可能需要apt-get install sendmail
3. celery -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>