使用带有 Celery 的 Django 发送电子邮件时出错

Question

我正在尝试发送电子邮件，如果通过网络服务器执行以下操作，则效果很好。但是，当我尝试将任务发送到 Celery 时，我总是收到一个断言错误返回，告诉我“to”需要是一个列表或元组。

我不希望通过网络服务器发送电子邮件，因为它会减慢速度，所以如果有人能帮我解决这个问题，我将不胜感激。

from celery import Celery
from django.core.mail import send_mail, EmailMessage

app = Celery('tasks', backend='amqp', broker='amqp://')

@app.task
def send_mail_link():
    subject = 'Thanks'
    message = 'body'
    recipients = ['someemail@gmail.com']
    email = EmailMessage(subject=subject, body=message, from_email='info@example.com', to=recipients)
    email.send()

Answer 1

我不是 100% 确定原因，但我做了一些更改，现在它可以正常工作了。

我删除了 send_mail 的导入并将方法名称从 send_mail_link() 更改为 send_link()。我还重新启动了 Celery worker，现在一切正常。

新代码是：

from celery import Celery
from django.core.mail import EmailMessage

app = Celery('tasks', backend='amqp', broker='amqp://')

@app.task
def send_link():
    subject = 'Thanks'
    message = 'body'
    recipients = ['someemail@gmail.com']
    email = EmailMessage(subject=subject, body=message, from_email='info@example.com', to=recipients)
    email.send()

希望将来有人会觉得这很有帮助。