我正在Django中构建REST API,用户可以在其中运行对象任务。我在下面创建了一个简单的示例,我使用事务轻松回滚对象的状态,以防任务失败。
from django.db import IntegrityError, transaction
def send_object(id):
obj = MyModel.objects.get(pk=id)
if obj.state != 'Created':
raise ValueError('Object not in state "Created"')
with transaction.atomic():
obj.state = 'Sending'
obj.save()
# send the object...
obj.state = 'Sent'
obj.save()
现在,我希望在任务运行时,通过API可以看到对象的状态。由于在任务完成之前不会提交事务,因此用户只能看到任务之前和之后的当前状态。
如果在任务期间发生系统故障/关闭并且对象陷入“发送”状态,我需要某种事务处理。必须重置状态,以便可以轻松地重试任务。
隔离级别设置为READ COMMITTED
,如果不更新代码的其他部分,则无法更改。
我可以在事务提交之前使新状态可用(即启用脏读)仅用于此事务吗?或者我还能做些什么吗?
基于this similar question和comments to this answer,您可以尝试使用具有不同隔离级别的两个数据库扩展。
以下代码来自链接的答案:
DATABASES = {
'default': {
'NAME': 'app_data',
'ENGINE': 'django.db.backends.postgresql',
'USER': 'postgres_user',
'PASSWORD': 's3krit',
},
'serializable': {
'NAME': 'app_data',
'ENGINE': 'django.db.backends.postgresl',
'USER': 'postgres_user',
'PASSWORD': 's3krit',
'OPTIONS': {
'isolation_level': psycopg2.extensions.ISOLATION_LEVEL_SERIALIZABLE,
},
},
}
您可以根据自己的需要进行更改(也许使用READ UNCOMMITED
而不是SERIALIZABLE
)然后告诉我们是否能解决您的问题。