import djcelery ###導(dǎo)包
djcelery.setup_loader() ###
BROKER_URL = 'redis://127.0.0.1:6379/2'
# BROKER_URL='redis://192.168.217.77:16379/2' #任何可用的redis都可以，不一定要在django server運(yùn)行的主機(jī)上
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' ### 
INSTALLED_APPS = [
 ...
 "djcelery",	# 加入djcelery應(yīng)用
 ...
 
]
CELERY_TIMEZONE='Asia/Shanghai' #并沒有北京時(shí)區(qū)，與下面TIME_ZONE應(yīng)該一致
TIME_ZONE='Asia/Shanghai' #

python manage.py migrate
#如若不成功可以嘗試一下命令語句
#python manage.py syncdb

# -*- coding: utf-8 -*-
import json, time
from syl.settings import ALY_ACCESSKEY_ID, ALY_ACCESSKEY_SECRET
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.request import CommonRequest
from celery import task
 
 
# 阿里云短信驗(yàn)證碼
 
@task
def Celery_Send_Sms(phone, data):
 client = AcsClient(ALY_ACCESSKEY_ID, ALY_ACCESSKEY_SECRET, 'cn-hangzhou')
 request = CommonRequest()
 request.set_accept_format('json')
 request.set_domain('dysmsapi.aliyuncs.com')
 request.set_method('POST')
 request.set_protocol_type('https') # https | http
 request.set_version('2017-05-25')
 request.set_action_name('SendSms')
 request.add_query_param('RegionId', "cn-hangzhou")
 request.add_query_param('PhoneNumbers', phone)
 request.add_query_param('SignName', "美多商城")
 request.add_query_param('TemplateCode', "SMS_205397849")
 request.add_query_param('TemplateParam', data)
 response = client.do_action(request)
 time.sleep(10)
 print(str(response, encoding='utf-8'))
 res = json.loads(str(response, encoding='utf-8'))
 
#celery運(yùn)行命令
# python manage.py celery worker --loglevel=info

import re
import random
from rest_framework.permissions import AllowAny
from django_redis import get_redis_connection
from rest_framework.views import APIView
from rest_framework.response import Response
# from utils.MyBaseView import send_message, Send_Sms
from verifications.stasks import Celery_Send_Sms
 
# 用戶注冊短信驗(yàn)證碼
class SmsCodeView(APIView):
 '''使用apiview的限流'''
 # 1. 所有人可以訪問
 permission_classes = (AllowAny,)
 
 def post(self, request):
  # 1. 獲取參數(shù)
  phone = request.data.get('phone') # 手機(jī)號
  image_code = request.data.get('image_code') # 字符串驗(yàn)證碼
  image_code_uuid = request.data.get('image_code_uuid') # 前端生成的uuid，是redis中圖片驗(yàn)證碼的key
 
  # 2. 檢查參數(shù)
  if not all([phone, image_code, image_code_uuid]):
   return Response({'code': 400, 'msg': '參數(shù)不全'})
 
  # 檢查手機(jī)號是否正確
  if not re.match(r'^1[3456789]\d{9}$', phone):
   return Response({"code": 999, "msg": "手機(jī)號碼不正確"})
 
  # 3. 檢查是否發(fā)送
  redis_client = get_redis_connection('img_code') # 連接redis數(shù)據(jù)庫
  # phone_exists = redis_client.get(phone)
  # if phone_exists:
  #  return Response({"code": 999, "msg": "頻繁發(fā)送, 請稍后再試"})
 
  # 4.檢查圖片驗(yàn)證碼是否合法
  redis_image_code = redis_client.get(image_code_uuid) # 字符串驗(yàn)證碼
  if redis_image_code:
   # bytes 轉(zhuǎn)成 string
   redis_image_code = redis_image_code.decode() # 把uuid解碼
 
  # 比較用戶提供的圖片內(nèi)容是否和redis中保存的一致
  if image_code.upper() != redis_image_code:
   return Response({'code': 999, 'msg': '圖片驗(yàn)證碼不正確'})
  # 5. 發(fā)送
  code = '%06d' % random.randint(100000, 999999) # 隨機(jī)6位驗(yàn)證碼
  print('code===============================================', code)
  # 使用容聯(lián)云短信驗(yàn)證碼
  # send_resp = send_message(phone, (code, "5"))
 
  # 使用阿里云短信驗(yàn)證碼
  data = {'code': code}
  # send_resp = Send_Sms(phone, data)
  # 使用celery異步發(fā)送短信
  Celery_Send_Sms.delay(phone, data) #delay是注冊為celery異步任務(wù)的關(guān)鍵點(diǎn)
  # Celery_Send_Sms(phone, data) # delay是注冊為celery異步任務(wù)的關(guān)鍵點(diǎn)
 
  # 5.1 保存code 到 redis中
  redis_client.setex(phone, 60 * 5, code) # phone:code, 5分鐘有效期
  # 5.2 從redis中刪除這個(gè)圖片驗(yàn)證碼, 以防再次被使用
  redis_client.delete(image_code_uuid)
 
  # 6.存儲這個(gè)已經(jīng)發(fā)送驗(yàn)證碼的手機(jī)號，防止頻繁發(fā)送（使用pipeline 批量操作 ）
  pl = redis_client.pipeline()
  pl.setex(phone, 60 * 5, code)
  pl.delete(image_code_uuid)
  pl.execute()
  # 7. 返回結(jié)果
  return Response({"code": 200, "msg": "短信發(fā)送成功"})

python manage.py celery worker --loglevel=info

from celery import Celery, platforms
platforms.C_FORCE_ROOT = True