0

0

Python 分布式事务的实现方式

冷炫風刃

冷炫風刃

发布时间:2026-02-17 16:16:38

|

526人浏览过

|

来源于php中文网

原创

python无开箱即用分布式事务支持,需用saga模式显式实现幂等正向与补偿操作,状态必须持久化到db或redis。

python 分布式事务的实现方式

Python 里没有开箱即用的分布式事务支持

标准库和主流 Web 框架(如 Flask、Django)本身不提供跨服务、跨数据库的事务一致性保障。transactionsqlite3commit() 只管本地资源;一旦涉及 HTTP 调用、消息队列、多个 DB 实例,ACID 就断了。

这不是 Python 的缺陷,而是分布式系统本质决定的:网络不可靠、节点独立故障、无法全局加锁。所以别指望靠一个装饰器或中间件“自动修复”两台机器上的转账一致性。

实际项目中怎么落地补偿逻辑(Saga 模式)

最常用、最可控的方式是显式编写正向操作 + 对应的补偿操作,由业务代码驱动状态推进与回滚。比如用户下单扣库存 → 创建订单 → 扣余额,任一环节失败,就按反序调用补偿函数。

  • saga 不是某个库的名字,而是一种模式;Python 里靠自己组织函数调用链即可,不需要引入复杂框架
  • 每个步骤必须幂等:cancel_order(order_id) 多次调用不能重复退款
  • 状态要持久化:用数据库字段记录当前执行到哪一步(如 status = "inventory_deducted"),避免重启后重复执行或跳步
  • 不要在内存里维护 saga 流程状态——进程挂了就丢,必须落库或写入 Redis 带过期时间的 key

示例片段:

立即学习Python免费学习笔记(深入)”;

V63积分商城 FOR DZ GBK
V63积分商城 FOR DZ GBK

v63积分商城特色功能:支持三种物品类型的发放1.实物:实物领取需要填写收货信息:2.虚拟:可以自定义用户领取需要填写的信息3.卡密:自动发放,后台能够查看编辑卡密状态支持三种种物品发放方式1.兑换:2.拍卖3. 抽奖兑换拍卖信息可以以帖子的形式自动发布当设定了“兑换拍卖自动发帖版块“ ID时,发布商品会自动在改ID版块生成帖子用户兑换或者出价后都会以跟帖的

下载
def create_order(user_id, item_id):
    # 正向操作
    inventory = db.query("SELECT stock FROM items WHERE id = %s", item_id)
    if inventory.stock < 1:
        raise ValueError("out of stock")
    db.execute("UPDATE items SET stock = stock - 1 WHERE id = %s", item_id)
    order_id = db.insert("INSERT INTO orders (...) VALUES (...)")
    return order_id
<p>def cancel_order(order_id):</p><h1>补偿操作:只还原库存,不删订单(留痕)</h1><pre class='brush:python;toolbar:false;'>db.execute("UPDATE items SET stock = stock + 1 WHERE id = (SELECT item_id FROM orders WHERE id = %s)", order_id)

Django/Flask 中调用外部服务时的事务边界陷阱

很多人误以为在 @transaction.atomic 里发 HTTP 请求,就能让远程服务也一起回滚。这是错的:HTTP 请求不受本地数据库事务控制,网络延迟、超时、5xx 错误都会导致状态不一致。

  • @transaction.atomic 只对当前 DB 连接生效,对 requests.post()kafka_producer.send() 完全无效
  • 如果先 commit 本地事务再发请求,失败后无法回滚已提交的数据 —— 必须把本地变更暂存在未提交状态,等远程确认成功后再 commit
  • 更稳妥的做法是:本地写入“待处理”状态(如 order.status = 'pending_payment'),异步轮询或监听 webhook 更新最终状态

什么时候该放弃强一致性,改用最终一致性

不是所有场景都值得为分布式事务付出复杂度代价。比如日志上报、通知推送、积分变动,允许几秒甚至几分钟延迟,那就别硬套 Saga。

  • 用消息队列(如 RabbitMQ、Kafka)解耦,生产者只管发事件,消费者各自重试处理
  • 关键字段加版本号或更新时间戳,消费端做去重和幂等判断(例如检查 event_id 是否已处理)
  • 监控缺失事件比写补偿逻辑更省事:定期扫描“卡在 pending 状态超过 5 分钟”的订单,人工介入或触发告警

真正难的从来不是写几个 try/except,而是判断哪条数据必须立刻一致、哪条可以晚点对齐——这个决策藏在业务规则里,不在代码里。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
Python Web 框架 Django 深度开发
Python Web 框架 Django 深度开发

本专题系统讲解 Python Django 框架的核心功能与进阶开发技巧,包括 Django 项目结构、数据库模型与迁移、视图与模板渲染、表单与认证管理、RESTful API 开发、Django 中间件与缓存优化、部署与性能调优。通过实战案例,帮助学习者掌握 使用 Django 快速构建功能全面的 Web 应用与全栈开发能力。

66

2026.02.04

rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

205

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

43

2026.01.28

Python Flask框架
Python Flask框架

本专题专注于 Python 轻量级 Web 框架 Flask 的学习与实战,内容涵盖路由与视图、模板渲染、表单处理、数据库集成、用户认证以及RESTful API 开发。通过博客系统、任务管理工具与微服务接口等项目实战,帮助学员掌握 Flask 在快速构建小型到中型 Web 应用中的核心技能。

97

2025.08.25

Python Flask Web框架与API开发
Python Flask Web框架与API开发

本专题系统介绍 Python Flask Web框架的基础与进阶应用,包括Flask路由、请求与响应、模板渲染、表单处理、安全性加固、数据库集成(SQLAlchemy)、以及使用Flask构建 RESTful API 服务。通过多个实战项目,帮助学习者掌握使用 Flask 开发高效、可扩展的 Web 应用与 API。

75

2025.12.15

什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

392

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

246

2023.10.07

什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

180

2024.05.11

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

283

2026.02.13

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.4万人学习

Django 教程
Django 教程

共28课时 | 4.3万人学习

SciPy 教程
SciPy 教程

共10课时 | 1.6万人学习

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

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