使用 django 信号发送电子邮件时使用 django celery 的问题？

问题描述

我使用默认的 Django 管理面板作为我的后端。我有一个博客模型。我想要做的是，每当管理员用户在 Django 管理员上保存 blogpost 对象时，我需要向时事通讯订阅者发送一封电子邮件，通知他们网站上有一个新博客。

我必须大量发送电子邮件，所以我使用 django-celery。 此外，我使用 django 信号来触发发送电子邮件功能。

但是现在，我发送时没有使用 celery，但是速度太慢了。

class Subscribers(models.Model):
    email = models.EmailField(unique=True)
    date_subscribed = models.DateField(auto_Now_add=True)

    def __str__(self):
        return self.email

    class Meta:
        verbose_name_plural = "Newsletter Subscribers"

    # binding signal:
    @receiver(post_save,sender=BlogPost)
    def send_mails(sender,instance,created,**kwargs):
        subscribers = Subscribers.objects.all()

        if created:
            blog = BlogPost.objects.latest('date_created')
            for abc in subscribers:
                emailad = abc.email
                send_mail('New Blog Post ',f" Checkout our new blog with title {blog.title} ",EMAIL_HOST_USER,[emailad],fail_silently=False)
        else:
            return

使用 celery 文档，我编写了以下文件。

我的 celery.py

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


os.environ.setdefault('DJANGO_SETTINGS_MODULE','travel_crm.settings')

app = Celery('travel_crm')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

Mu 初始化文件：

from __future__ import absolute_import,unicode_literals
from .celery import app as celery_app
__all__ = ('celery_app',)

来自文档的任务文件：

 def my_first_task(duration):
        subject= 'Celery'
        message= 'My task done successfully'
        receiver= '[e-mail]'
        is_task_completed= False
        error=''
        try:
            sleep(duration)
            is_task_completed= True
        except Exception as err:
            error= str(err)
            logger.error(error)
        if is_task_completed:
            send_mail_to(subject,message,receivers)
        else:
            send_mail_to(subject,error,receivers)
        return('first_task_done')

此任务不起作用，因为我正在使用 Django 信号来触发发送电子邮件功能，如何将其应用到 tasks.py 中

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）