qidao123.com技术社区-IT企服评测·应用市场

标题: 深入解析事件基础与原子操作原理 [打印本页]

作者: 星球的眼睛 时间: 2025-4-23 11:20
标题: 深入解析事件基础与原子操作原理
title: 深入解析事件基础与原子操作原理
date: 2025/04/23 12:07:08
updated: 2025/04/23 12:07:08
author: cmdragon
excerpt:
事件是数据库操作的核心，需满足ACID特性：原子性、一致性、隔离性和持久性。事件隔离级别包括读未提交、读已提交、可重复读和串行化，实用于不同场景。嵌套事件通过上下文管理实现，支持回滚点以部分回滚。实战案例展示了订单体系中的事件处理，包括余额查抄和付出失败回滚。常见错误如TransactionManagementError和死锁，需通过精确使用事件装饰器和重试机制办理。课后Quiz探究了事件隔离和嵌套事件回滚的处理方法。运行情况设置包括依赖安装和FastAPI启动设置。
categories:

后端开辟
FastAPI

tags:

事件处理
ACID特性
嵌套事件
回滚点
订单体系
事件隔离级别
数据库操作

扫描二维码关注或者微信搜一搜：编程智域前端至全栈交流与成长
探索数千个预构建的 AI 应用，开启你的下一个伟大创意
1. 事件基础与原子操作原理

1.1 事件的ACID特性

在数据库操作中，事件必要满足ACID特性：

原子性（Atomicity）：操作要么全部乐成，要么全部失败
一致性（Consistency）：保持数据库的完整性束缚
隔离性（Isolation）：并发事件相互隔离
持久性（Durability）：提交后永世保存

# 示例：银行转账的原子操作
from fastapi import APIRouter, Depends
from tortoise.transactions import atomic
router = APIRouter()
@router.post("/transfer")
@atomic() # 使用装饰器包裹事务范围
async def transfer_money(
from_account: str,
to_account: str,
amount: float
):
# 扣减转出账户
from_acc = await Account.get(number=from_account)
from_acc.balance -= amount
await from_acc.save()
# 增加转入账户
to_acc = await Account.get(number=to_account)
to_acc.balance += amount
await to_acc.save()
return {"message": "转账成功"}

复制代码

1.2 事件隔离级别对比

级别脏读不可重复读幻读实用场景读未提交大概大概大概低并发场景读已提交禁止大概大概默认级别可重复读禁止禁止大概金融体系串行化禁止禁止禁止高精度要求2. 嵌套事件实现与回滚点

2.1 嵌套事件上下文管理

from tortoise.transactions import in_transaction
async def complex_operation():
async with in_transaction() as conn1: # 外层事务
await Model1.create(...)
try:
async with in_transaction(connection=conn1) as conn2: # 内层事务
await Model2.create(...)
await conn2.rollback() # 仅回滚内层操作
except Exception:
pass
await Model3.create(...) # 外层事务继续执行

复制代码

2.2 回滚点（Savepoint）使用

async def savepoint_demo():
async with in_transaction() as conn:
savepoint = await conn.savepoint() # 创建回滚点
try:
await Model.create(...)
if error_condition:
await savepoint.rollback() # 回滚到保存点
except Exception:
await savepoint.rollback()

复制代码

3. 完整实战案例：订单体系

from fastapi import Depends
from tortoise.contrib.fastapi import register_tortoise
from tortoise.models import Model
from tortoise import fields
# 数据模型定义
class User(Model):
id = fields.IntField(pk=True)
balance = fields.DecimalField(max_digits=10, decimal_places=2)
class Order(Model):
id = fields.UUIDField(pk=True)
user = fields.ForeignKeyField('models.User')
amount = fields.DecimalField(max_digits=10, decimal_places=2)
status = fields.CharField(max_length=20)
# 事务处理服务
class OrderService:
@staticmethod
@atomic()
async def create_order(user_id: int, amount: float):
user = await User.get(id=user_id)
# 检查余额
if user.balance < amount:
raise ValueError("余额不足")
# 扣减余额
user.balance -= amount
await user.save()
# 创建订单记录
order = await Order.create(
user=user,
amount=amount,
status="PENDING"
)
# 模拟第三方支付调用
if not await call_payment_gateway():
await OrderService.rollback_order(order.id)
raise Exception("支付失败")
return order
@staticmethod
@atomic()
async def rollback_order(order_id: str):
order = await Order.get(id=order_id)
user = await order.user
# 恢复用户余额
user.balance += order.amount
await user.save()
# 更新订单状态
order.status = "CANCELED"
await order.save()

复制代码

4. 常见报错办理方案

4.1 TransactionManagementError

错误征象：
TransactionManagementError: Transaction not found for current context
办理方法：

查抄事件装饰器的使用范围
确保异步函数精确使用async/await
验证数据库连接设置是否精确

4.2 死锁检测

错误日志：
Deadlock found when trying to get lock
处理方案：

from tortoise.exceptions import OperationalError
from fastapi import HTTPException
async def safe_transaction():
try:
async with in_transaction():
# 数据库操作
except OperationalError as e:
if "Deadlock" in str(e):
await asyncio.sleep(0.1) # 随机延迟后重试
return await safe_transaction()
else:
raise HTTPException(status_code=500, detail="数据库错误")

复制代码

5. 课后Quiz

5.1 事件隔离问题

问题：在可重复读隔离级别下，如何处理余额校验时的并发修改？
答案解析：
使用SELECT FOR UPDATE锁定记录：

async def update_balance(user_id: int):
async with in_transaction():
user = await User.select_for_update().get(id=user_id)
# 后续操作

复制代码

5.2 嵌套事件回滚

问题：当外层事件捕获内层事件的非常时，如何保证部分提交？
精确答案：
使用保存点机制：

async def nested_transaction():
async with in_transaction() as conn:
savepoint = await conn.savepoint()
try:
# 内层操作
except Exception:
await savepoint.rollback()
# 外层继续执行

复制代码

6. 运行情况设置

安装依赖：

pip install fastapi tortoise-orm uvicorn pydantic

复制代码

启动设置：

# main.py
from fastapi import FastAPI
app = FastAPI()
register_tortoise(
app,
db_url='sqlite://db.sqlite3',
modules={'models': ['models']},
generate_schemas=True,
add_exception_handlers=True
)

复制代码

启动命令：

uvicorn main:app --reload

复制代码

余下文章内容请点击跳转至个人博客页面或者扫码关注或者微信搜一搜：编程智域前端至全栈交流与成长，阅读完整的文章：深入解析事件基础与原子操作原理 | cmdragon's Blog
往期文章归档：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/)