1. 程式人生 > 程式設計 >Django之使用內建函式和celery發郵件的方法示例

Django之使用內建函式和celery發郵件的方法示例

郵箱配置

開啟stmp服務

以163郵箱為例,點選設定裡面的stmp

開啟客戶端授權密碼

如上所示,因為我已經開啟了,所以出現的是以上頁面。

這樣,郵箱的準備就已經完成了。

使用Django內建函式發郵件

1.在settings檔案中加入以下配置

# 郵件設定
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
# 傳送郵件的郵箱
EMAIL_HOST_USER = '傳送郵件的郵箱'
# 在郵箱中設定的客戶端授權密碼
EMAIL_HOST_PASSWORD = '授權密碼'
# 收件人看到的發件人
EMAIL_FROM = '綠色果園<傳送郵件的郵箱>'

2.編寫傳送郵件程式碼

from django.shortcuts import render,redirect,HttpResponse
from django.core.mail import send_mail
from itsdangerous import TimedJSONWebSignatureSerializer as Serializer
from django.conf import settings

def emailtest(request):
  # 傳送啟用郵件,包括啟用連結:http://127.0.0.1:8000/user/active/3
  # 啟用連結中需要包含使用者的身份資訊,並且要把身份資訊進行加密
  # 加密使用者的身份資訊,生成啟用token
  userid = 3
  email = "接收郵件的郵箱賬號"
  serializer = Serializer(settings.SECRET_KEY,1800)
  info = {'confirm': userid}
  token = serializer.dumps(info)
  token = token.decode()
  # 發郵件
  subject = "綠色果園歡迎資訊"
  message = ""
  sender = settings.EMAIL_FROM
  receiver = [email]
  html_message = "<h2>歡迎你成為綠色果園註冊會員</h2></br>請點選以下連結啟用賬號<a href='http:127.0.0.1:8000/" \
          "user/active/%s'>http:127.0.0.1:8000/user/active/%s</a>" % (token,token)
  send_mail(subject,message,sender,receiver,html_message=html_message)

  # 返回應答,跳轉到首頁
  return HttpResponse("郵件傳送成功,請注意接收")

配套url

urlpatterns = [
  url(r'^emailtest/$',views.emailtest,name="emailtest"),# 發郵件測試
]

3.在瀏覽器中輸入如下地址,即可看到“郵件已傳送”的提示資訊

http://127.0.0.1:8000/user/emailtest/

接收郵件如下圖所示

收到郵件

郵件內容詳情

使用celery發郵件

使用django內建的函式傳送郵件時,django給stmp伺服器傳送郵件需要時間,stmp伺服器傳送郵件給使用者也需要時間,而在傳送郵件這段時間內,使用者是在等服務端返回應答的,如果等待時間過長,那麼無疑會大大的降低使用者的體驗。

這個時候,我們可以使用celery來非同步傳送郵件,即Django服務端在celery傳送郵件的同時,返回應答給使用者。這裡,我們使用sleep來模擬傳送郵件的時常。

1.安裝celery

pip install celery

2.配置settings檔案

# 郵件設定
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
EMAIL_HOST = 'smtp.163.com'
EMAIL_PORT = 25
# 傳送郵件的郵箱
EMAIL_HOST_USER = '傳送郵件的郵箱'
# 在郵箱中設定的客戶端授權密碼
EMAIL_HOST_PASSWORD = '客戶端授權密碼'
# 收件人看到的發件人
EMAIL_FROM = '綠色果園<傳送郵件的郵箱>'

# diango的快取配置
CACHES = {
  "default": {
    "BACKEND": "django_redis.cache.RedisCache","LOCATION": "redis://127.0.0.1:6379/9","OPTIONS": {
      "CLIENT_CLASS": "django_redis.client.DefaultClient",}
  }
}

3.在專案下新建celery_tasks資料夾,在資料夾中新建tasks檔案, 編寫tasks檔案

from django.core.mail import send_mail
from django.conf import settings
from celery import Celery
import time

# 在任務處理者一端時需要加這幾句
# import os
# import django
# os.environ.setdefault("DJANGO_SETTINGS_MODULE","專案名.settings")
# django.setup()

# 建立一個Celery類的例項物件
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 = "<h2>%s, 歡迎你成為綠色果園註冊會員</h2></br>請點選以下連結啟用賬號<a href='http:127.0.0.1:8000/" \
          "user/active/%s'>http:127.0.0.1:8000/user/active/%s</a>" % (username,token,html_message=html_message)
  time.sleep(5)

4.在傳送郵件的地方 呼叫 celery_tasks下的tasks下的 傳送郵件函式

from django.shortcuts import render,HttpResponse
from django.core.mail import send_mail
from itsdangerous import TimedJSONWebSignatureSerializer as Serializer
from django.conf import settings

def emailtest(request):
  # 傳送啟用郵件,包括啟用連結:http://127.0.0.1:8000/user/active/3
  # 啟用連結中需要包含使用者的身份資訊,並且要把身份資訊進行加密
  # 加密使用者的身份資訊,生成啟用token
  userid = 3
  username = "mumun"
  email = "收郵件的郵箱"
  serializer = Serializer(settings.SECRET_KEY,1800)
  info = {'confirm': userid}
  token = serializer.dumps(info)
  token = token.decode()
  # 使用celery傳送郵件
  send_register_active_email.delay(email,token)

  # 返回應答,跳轉到首頁
  return HttpResponse("郵件傳送成功,請注意接收")

配套url

urlpatterns = [
  url(r'^emailtest/$',# 發郵件測試
]

5.開啟redis服務;

E:\>cd E:\YifChanSoft\Database\Redis\RedisSoft\Redis-x64-3.2.100

E:\YifChanSoft\Database\Redis\RedisSoft\Redis-x64-3.2.100>redis-server --service-install redis.windows-service.conf --loglevel verbose

E:\YifChanSoft\Database\Redis\RedisSoft\Redis-x64-3.2.100>redis-cli
127.0.0.1:6379> select 8
OK
127.0.0.1:6379[8]> keys *
(empty list or set)
127.0.0.1:6379[8]> keys *
1) "_kombu.binding.celery"
2) "_kombu.binding.celery.pidbox"
3) "_kombu.binding.celeryev"

開啟redis服務截圖

6.將專案程式碼拷貝一份放在某處,進入該處, 啟動tasks的worker模式

注意,用作worker的程式碼的tasks檔案中應該有提前啟動django的初始化的程式碼,不然worker沒法呼叫conf資訊;

即應該有以下內容

# 在任務處理者一端時需要加這幾句
import os
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE","專案名.settings")
django.setup()

開啟worker模式:

celery -A celery_tasks.tasks worker -l info

出現問題,報錯如下

ValueError: not enough values to unpack (expected 3,got 0)

原因

win10上執行celery4.x就會出現這個問題

解決

pip install eventlet

並在開啟worker模式時加入引數

celery -A celery_tasks.tasks worker -l info -P eventlet

開啟worker模式截圖,後面還有內容,但因為太多了,就只截一半

7.在瀏覽器中輸入如下地址,即可看到“郵件已傳送”的提示資訊

http://127.0.0.1:8000/user/emailtest/

接收郵件如下

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。