Cell sends SMS asynchronously

1.Celery

install celery
celery, Distributed asynchronous task queue pip install celery==4.4.7

eventlet, Concurrent Network Library gevent Process library pip install eventlet==0.26.1

Celery It's based on python Distributed asynchronous task queue , The server submits the task ,celery Handle , The server sends the processed response to the client , It does not affect the operation of the following programs

• Asynchronous task , For example, sending text messages , Message push 、 Audio processing
• Do timed tasks
• have access to celery Implement a simple distributed crawler system

1.1 Celery analysis

1. Task -- Mission
2. Borker -- Message middleware , To receive tasks and send task information , Save task queue
3. Worker– Background execution tasks , Monitor whether there are tasks in the queue , If there is one, execute it immediately
4. Backend– Save task execution results

2. Send SMS asynchronously

2.1 To configure celery

Create a file under the project name celery.py file

from celery import Celery
from django.conf import settings
import os

#  Configure environment variables 
os.environ.setdefault("DJANGO_SETTINGS_MODULE",'p6.settings')

#  Instantiation celery object 
app = Celery("cc")
#  Through the configuration file   To configure 
app.config_from_object("p6.config")

#  Give Way app Auto discovery task function 
app.autodiscover_tasks(settings.INSTALLED_APPS)

Create... Under this file config.py File store celery Information

broker_url = "redis://:[email protected]:6379/5"
result_backend = "redis://:[email protected]:6379/6"

2.2 Mission

Create under the sub application file tasks.py

from p6.celery import app
from ronglian_sms_sdk import SmsSDK
import json



accId = "8aaf07088185853e01818a75a87a016f"
accToken = "6b755e025dc2436a8e3b7b82ef9ac20c"
appId = "8aaf07088185853e01818a75a9a00176"

#  Define the function of sending SMS 
#  Define task functions 
@app.task
def send_message(sms_code,mobile,expire=5):
    """ :param sms_code:  The verification code to be sent  :param mobile:  Mobile number sent  :param expire:  Expiration time  :return: """
    #  Instantiation sdk object 
    sdk = SmsSDK(accId = accId,accToken=accToken,appId=appId)

    #  Prepare the data 
    tid="1"
    datas = ("%s"%sms_code,"%s"%expire) #  SMS code , Expiration time formal parameter tuple 
    #  Send a text message 
    res = sdk.sendMessage(tid=tid,mobile=mobile,datas=datas)
    #  analysis json character string 
    data = json.loads(res)
    print(" Data responded by Ronglian cloud :",data)
    return data

2.3 View submit task

#  SMS verification code view 
import redis
from .tasks import send_message
class SmsCodeAPIView(APIView):
    #  Send SMS verification code 
    def get(self,request):
        # 1. Get the front-end mobile number 
        mobile = request.query_params.get("mobile")
        #  Generate random code 
        sms_code = str(random.randint(10000,99999))
        send_message.delay(sms_code,mobile) #  Send SMS verification code asynchronously 
        r = redis.Redis(host='127.0.0.1', port=6379, password='123123')
        key = "sms_%s" % mobile
        r.set(key, sms_code, ex=300)

        return Response({
    "code": 200, "msg": ' SMS sent , Please remember to check '})

2.4 start-up celery

Open two terminals , One boot celery, One boot django

celery -A p6 worker -l info -P eventlet