Osk*_*son 3 django transactions task
我正在 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()
Run Code Online (Sandbox Code Playgroud)
现在,我希望在任务运行时,用户可以通过 API 看到对象的状态。由于事务在任务完成之前不会提交,因此用户只能看到任务之前和之后的当前状态。
我需要某种事务,以防在任务期间发生系统故障/关闭并且对象卡在“发送”状态。必须重置状态,以便可以轻松重试任务。
隔离级别已设置为,READ COMMITTED并且在不更新代码其他部分的情况下无法更改。
我可以在提交事务之前使新状态可用(即启用脏读)吗?或者还有什么我可以做的吗?
基于这个类似的问题和对此答案的评论,您可以尝试使用具有不同隔离级别的两个数据库连接。
以下代码来自链接的答案:
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,
},
},
}
Run Code Online (Sandbox Code Playgroud)
您可以更改它以满足您的需求(也许可以使用READ UNCOMMITED)SERIALIZABLE,然后让我们知道这是否可以解决您的问题。
| 归档时间: |
|
| 查看次数: |
595 次 |
| 最近记录: |