使用Django Celery进行短信发送

2023-04-11 00:00:00 django celery 短信发送

使用Django Celery进行短信发送，需要进行以下步骤：

  1. 安装 celery、redis、Django celery等必要库：
pip install celery redis django-celery
  1. 配置Celery：

在Django项目的settings.py文件中增加以下配置：

# Redis作为消息队列
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

# 定义任务模块的名称
CELERY_IMPORTS = ('yourapp.tasks', )

# 定义时区
CELERY_TIMEZONE = 'Asia/Shanghai'

# 设定任务执行结果过期时间
CELERY_TASK_RESULT_EXPIRES = 60 * 60 * 24

# 任务失败重试的次数
CELERYD_MAX_RETRIES = 3

# 任务失败重试的时间间隔
CELERYD_TASK_TIME_LIMIT = 30 * 60
  1. 编写短信发送任务模块：

在Django项目的某个app下创建tasks.py文件，编写发送短信的任务函数：

from celery.decorators import task
from celery.utils.log import get_task_logger
from yourapp.sms import SmsSender

logger = get_task_logger(__name__)

@task
def send_sms(phone, content):
    sender = SmsSender('pidancode.com', '皮蛋编程') # 短信发送实例
    try:
        res = sender.send(phone, content)
        logger.info('Send SMS success! The result: {0}'.format(res))
    except Exception as e:
        logger.error(e)
        send_sms.retry(countdown=60, exc=e)# 重试发送短信任务

其中，phone是接受短信的手机号，content是短信内容。在send_sms任务中，我们使用了一个SmsSender类来发送短信（该类需要根据你的实际需求进行编写）。

  1. 在视图中调用任务：

在Django的视图函数中，我们可以通过apply_async()方法来调用send_sms任务：

from yourapp.tasks import send_sms

def send_somthing(request):
    # some code here
    send_sms.apply_async(args=[phone, content]) # 异步调用send_sms任务
    # some code here
  1. 启动redis和celery：

使用以下命令启动redis：

redis-server /etc/redis/redis.conf

使用以下命令启动Celery：

celery -A yourprojectname worker -l info

以上是使用Django Celery进行短信发送的基本步骤，根据具体的情况需要进行适当的修改和优化。

相关文章