Django中使用celery的举例

Django中使用celery的一个例子是，当用户提交一个长时间运行的任务，而该任务不应阻塞主线程时，可以使用celery将任务放在任务队列中异步处理。可以通过定义一个异步任务函数，使用celery的装饰器将其标记为任务，然后将其添加到任务队列中。例如，以下是一个使用celery异步处理发送电子邮件的函数：

from celery.decorators import task
from django.core.mail import send_mail

@task
def send_email_task(subject, message, from_email, recipient_list):
    send_mail(
        subject=subject,
        message=message,
        from_email=from_email,
        recipient_list=recipient_list,
        fail_silently=False,
    )

然后，可以在您的Django视图中调用此函数，将其添加到任务队列中并立即返回响应以防止阻塞主线程。

from django.shortcuts import render
from .tasks import send_email_task

def send_email_view(request):
    # ... 获取电子邮件相关的数据 ...
    send_email_task.delay(subject, message, from_email, recipient_list)
    return render(request, 'email_sent.html')

这样，当用户提交发送邮件的请求时，函数将被添加到celery任务队列中进行异步处理，而不会阻塞主线程。