Django dj芹菜:构建事务性任务不是回滚

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