django djcelery：构建事务性任务不会回滚

Question

我正在尝试执行事务性任务，如果无法发送电子邮件，该任务将回滚数据库更新。

以下是我的代码，任何人都可以建议这里做错了什么？

from celery.task import task
from django.core.mail import send_mail, send_mass_mail
from django.db import transaction


@task(name='communicator.process_emails')
@transaction.commit_manually
def process_emails():
    from models import Comm_Queue
    try:
        message = []
        for i in Comm_Queue.objects.filter(status='P').order_by('sender_email'):
            message.append((i.subject, i.content, i.sender_email, [i.recipient_email]))
            Comm_Queue.objects.filter(id=i.id).update(status='S')
        if send_mass_mail(message):
            transaction.commit()
    except Exception, e:
        print 'rolled back (exception): %s' % e.__str__()
        transaction.rollback()

Answer 1

由于您使用的是 MySQL，首先需要检查的是您使用的数据库引擎是否支持事务，以及是否在 MySQL 配置中启用了事务。

有关 MySQL/Django 事务问题的更多信息，请参阅此链接：https://docs.djangoproject.com/en/dev/ref/databases/#storage-engines