0

0

Django ORM 中安全处理并发更新的最佳实践

碧海醫心

碧海醫心

发布时间:2025-12-31 16:25:52

|

741人浏览过

|

来源于php中文网

原创

Django ORM 中安全处理并发更新的最佳实践

在异步 telegram 机器人中使用 django orm 执行原子性扣减与累加操作时,需通过数据库级锁(如 `select_for_update`)和事务封装(`transaction.atomic`)避免竞态条件,推荐结合 `f()` 表达式实现无状态、线程/协程安全的字段更新。

Django ORM 完全适用于高并发场景下的数据一致性保障,但必须正确使用其并发控制机制。你示例中的代码存在两个关键风险点:一是 obj1.filed1 > 0 判断后到 save() 之间存在时间窗口,多请求可能同时通过判断并重复扣减;二是两次 save() 非原子操作,若中间出错会导致数据不一致。

推荐方案:事务 + select_for_update() + F() 表达式

睿拓智能网站系统-网上商城
睿拓智能网站系统-网上商城

睿拓智能网站系统-网上商城1.0免费版软件大小:5M运行环境:asp+access本版本是永州睿拓信息专为电子商务入门级用户开发的网上电子商城系统,拥有产品发布,新闻发布,在线下单等全部功能,并且正式商用用户可在线提供多个模板更换,可实现一般网店交易所有功能,是中小企业和个人开展个人独立电子商务商城最佳的选择,以下为详细功能介绍:1.最新产品-提供最新产品发布管理修改,和最新产品订单查看2.推荐产

下载
from django.db import transaction
from django.db.models import F

async def on_button_click():
    try:
        with transaction.atomic():
            # 使用 select_for_update() 加行级写锁(需确保数据库支持,如 PostgreSQL/MySQL InnoDB)
            obj1 = Object1.objects.select_for_update().get(id=X)

            if obj1.field1 >= N:  # 注意:>= 避免扣成负数
                # 原子更新:所有计算在数据库层面完成,无需读取-修改-写入(RMW)循环
                Object1.objects.filter(id=X).update(field1=F('field1') - N)
                Object2.objects.filter(id=X2).update(field2=F('field2') + N)
            else:
                raise ValueError("Insufficient balance")
    except Object1.DoesNotExist:
        raise ValueError("Object1 not found")
    except Exception as e:
        # 日志记录 & 用户反馈
        logger.warning(f"Button click failed: {e}")
        raise

? 关键要点说明:

  • transaction.atomic() 确保整个块为数据库事务,失败则回滚;
  • select_for_update() 在 obj1 行上加排他锁,阻塞其他并发事务对该行的 SELECT ... FOR UPDATE 或 UPDATE,直到当前事务结束;
  • F() 表达式使更新脱离 Python 层计算,直接由数据库执行(如 SET field1 = field1 - N),彻底规避读-改-写竞态;
  • 锁定范围应精准:仅锁定实际参与更新的行(如 Object1.objects.select_for_update().get(id=X)),避免锁表或锁过多行影响性能;
  • ⚠️ 注意:select_for_update() 在 SQLite 中不生效,在 MySQL 中需启用 READ-COMMITTED 或更高隔离级别,在 PostgreSQL 中默认支持;

? 异步兼容性提示:
Django 4.1+ 原生支持异步视图与 ORM 调用,但 select_for_update() 和 transaction.atomic() 目前仍要求同步上下文(即需在 sync_to_async 包装器中执行)。Pyrogram 的异步 handler 中应这样调用:

from asgiref.sync import sync_to_async

# 在 async handler 中:
await sync_to_async(on_button_click_sync)()  # 其中 on_button_click_sync 是上述同步事务函数

? 替代思路(进阶):
若业务逻辑更复杂(如需校验多个条件、触发事件链),可考虑使用数据库原生 UPDATE ... RETURNING(PostgreSQL)或乐观锁(添加 version 字段 + WHERE version = old_version 条件更新),但对绝大多数余额类场景,atomic + select_for_update + F() 组合已足够健壮、简洁且可维护。

相关专题

更多
python开发工具
python开发工具

php中文网为大家提供各种python开发工具,好的开发工具,可帮助开发者攻克编程学习中的基础障碍,理解每一行源代码在程序执行时在计算机中的过程。php中文网还为大家带来python相关课程以及相关文章等内容,供大家免费下载使用。

715

2023.06.15

python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

625

2023.07.20

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

739

2023.07.25

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

617

2023.07.31

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

1235

2023.08.03

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

547

2023.08.04

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

575

2023.08.04

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

698

2023.08.11

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

2

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
MySQL 教程
MySQL 教程

共48课时 | 1.5万人学习

MySQL 初学入门(mosh老师)
MySQL 初学入门(mosh老师)

共3课时 | 0.3万人学习

简单聊聊mysql8与网络通信
简单聊聊mysql8与网络通信

共1课时 | 777人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号