Django更新后读取无法获取最新值问题咨询

首先，你的问题核心大概率不是数据库隔离级别本身，而是事务提交时机与WebSocket发送顺序不匹配，再加上Uvicorn多工作进程的数据库连接隔离特性导致的。下面分点解答你的问题并给出建议：

1. 改为SERIALIZABLE隔离级别能否解决问题？ #

可以，但这是代价很高的“过度解决方案”：

• SERIALIZABLE是MariaDB最高隔离级别，会强制所有事务按串行顺序执行，彻底避免不可重复读、幻读以及并发更新导致的读旧数据问题。
• 但副作用明显：高并发场景下会大幅降低吞吐量，数据库锁竞争加剧，死锁概率上升，系统响应变慢。
• 如果你的问题根源是事务提交顺序（而非隔离级别导致的并发读问题），改SERIALIZABLE只会浪费性能，无法从根本上解决问题。

2. 能否为特定表设置不同隔离级别？ #

MariaDB不支持表级别的隔离级别设置，但可以针对特定会话/事务设置隔离级别，实现对特定操作的严格锁控制：

• Django提供了transaction.set_isolation_level()方法，可在局部事务中临时修改隔离级别，不影响全局设置。示例代码：

from django.db import transaction

# 仅在这个事务块内使用SERIALIZABLE级别
with transaction.atomic():
    transaction.set_isolation_level(transaction.SERIALIZABLE)
    # 执行状态更新操作
    instance = MyModel.objects.get(pk=pk)
    instance.status = validated_data["status"]
    instance.save()

# 确保事务提交后再发送WebSocket消息
transaction.on_commit(lambda: send_websocket_notification())

3. 优先推荐的根本解决方案 #

你的问题最可能是WebSocket消息在事务提交前就已发送，导致客户端立刻发起的GET请求，在其他Uvicorn工作进程的数据库连接中读取到未提交的旧数据。解决步骤：

步骤1：延迟WebSocket发送到事务提交后 #

使用Django的transaction.on_commit()钩子，确保只有当更新事务成功提交到数据库后，才向客户端推送WebSocket消息：

from django.db import transaction
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

def update_status(instance, validated_data):
    instance.status = validated_data["status"]
    instance.save()
    
    # 事务提交后再发送WebSocket
    def send_ws():
        channel_layer = get_channel_layer()
        async_to_sync(channel_layer.group_send)(
            "status_updates",
            {"type": "status_update", "data": {"id": instance.pk}}
        )
    transaction.on_commit(send_ws)
    return instance

步骤2：针对高并发更新的额外优化 #

如果确实存在并发更新导致的冲突，可结合行锁进一步保证数据一致性：

• 使用select_for_update()在更新前锁定目标实例，避免其他事务同时修改：

instance = MyModel.objects.select_for_update().get(pk=pk)
instance.status = validated_data["status"]
instance.save()

4. 其他排查点 #

• 检查Django的事务自动提交设置：确保你的更新操作所在的视图/函数没有手动禁用自动提交，导致事务未及时提交。
• 验证Uvicorn工作进程的数据库连接：每个Uvicorn worker进程拥有独立的数据库连接池，事务提交仅对当前进程的连接可见，这也是提前发WebSocket会导致其他进程读旧数据的原因。

内容的提问来源于stack exchange，提问作者gilbertc