代码之家 › 专栏 › 技术社区 › Anuj TBE

django邮件队列电子邮件不使用芹菜发送

django-celery celery django

Anuj TBE · 技术社区 · 6 年前

应用程序托管在 赫罗库 以及使用 redis公司 的后端芹菜

这个文件包含

##################
# CELERY STUFF
##################
BROKER_URL = os.getenv('REDIS_URL', 'redis://localhost:6379')
CELERY_RESULT_BACKEND = os.getenv('REDIS_URL', 'redis://localhost:6379')
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

#######################
# Django mail queue
#######################
MAILQUEUE_CELERY = True
MAILQUEUE_QUEUE_UP = False

发送电子邮件

new_message = MailerMessage()
new_message.subject = subject
new_message.to_address = to
new_message.from_address = from_email
new_message.content = text_content
new_message.html_content = html_content
new_message.app = 'Koober'
new_message.save()

设置 MAILQUEUE_CELERY = False 和 MAILQUEUE_QUEUE_UP = False 正在成功发送电子邮件。

但这会在出现异常时导致应用程序失败。所以我想用在后台发送电子邮件。

应用程序/芹菜.py

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

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'koober.settings')
app = Celery('koober')

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))