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