一个 Flask 开发的 REST API 项目，功能是管理电商平台的订单数据，涉及多表操作，比如订单表和库存表。生产环境跑了一段时间后，API 在高并发场景下开始报错，提示数据库死锁，订单更新失败。这问题让我抓狂了半天，记录下排查和解决的过程，分享点经验。

 端点，用户下单时会同时更新订单表（插入新订单）和库存表（扣减库存）。正常情况下，请求 200ms 内返回。但高峰期，部分请求报 500 错误，MySQL 抛出 

Deadlock found when trying to get lock; try restarting transaction

。更烦的是，这问题断续发生，重试有时候能成功，有时候直接挂，成功率掉到 80% 左右，用户体验很差。

 模拟高并发，100 个用户并发请求 

，果然触发了死锁。错误日志指向 SQLAlchemy 的 

 方法，MySQL 的错误码是 1213。查了下，这是典型的死锁错误，通常是多个事务竞争同一资源导致。

from flask import Flask, request
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy.exc import SQLAlchemyError

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://user:pass@mysql:3306/ecommerce'
db = SQLAlchemy(app)

class Order(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    product_id = db.Column(db.Integer)
    quantity = db.Column(db.Integer)

class Inventory(db.Model):
    product_id = db.Column(db.Integer, primary_key=True)
    stock = db.Column(db.Integer)

@app.route('/order/create', methods=['POST'])
def create_order():
    data = request.json
    product_id = data['product_id']
    quantity = data['quantity']
    
    try:
        with db.session.begin():
            # 检查库存
            inventory = Inventory.query.filter_by(product_id=product_id).with_for_update().first()
            if inventory.stock < quantity:
                return {"error": "Insufficient stock"}, 400
            # 创建订单
            order = Order(product_id=product_id, quantity=quantity)
            db.session.add(order)
            # 扣减库存
            inventory.stock -= quantity
            db.session.commit()
        return {"message": "Order created"}, 201
    except SQLAlchemyError as e:
        db.session.rollback()
        return {"error": str(e)}, 500

 锁定了库存行，避免并发修改，但死锁还是发生了。

 查看死锁详情，发现死锁发生在 

 表之间。两个事务在不同顺序锁定这两张表：一个事务先锁 

，另一个反过来，导致交叉等待。我猜是并发请求中，事务的执行顺序不一致。

 没索引，导致插入时可能触发全表扫描，延长了事务时间。加上索引：

CREATE INDEX idx_order_product_id ON Order(product_id);

但死锁还是偶发，说明索引只是缓解了问题，没解决根因。

死锁的核心是两个事务以不同顺序锁表。我检查了代码，发现另一个端点 

 表，但锁顺序相反。决定统一锁顺序，先锁 

改进了代码，统一锁顺序，并加了重试机制处理偶发死锁：

from flask import Flask, request
from flask_sqlalchemy import SQLAlchemy
from tenacity import retry, stop_after_attempt, wait_fixed
from sqlalchemy.exc import SQLAlchemyError
import logging

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://user:pass@mysql:3306/ecommerce'
db = SQLAlchemy(app)
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
logger = logging.getLogger(__name__)

class Order(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    product_id = db.Column(db.Integer)
    quantity = db.Column(db.Integer)

class Inventory(db.Model):
    product_id = db.Column(db.Integer, primary_key=True)
    stock = db.Column(db.Integer)

@retry(stop=stop_after_attempt(3), wait=wait_fixed(1), after=lambda x: logger.warning("Retrying due to deadlock"))
def process_order(product_id, quantity):
    try:
        with db.session.begin():
            # 先锁 Order 表
            order = Order(product_id=product_id, quantity=quantity)
            db.session.add(order)
            db.session.flush()  # 确保 Order 插入完成
            # 再锁 Inventory 表
            inventory = Inventory.query.filter_by(product_id=product_id).with_for_update().first()
            if inventory.stock < quantity:
                raise ValueError("Insufficient stock")
            inventory.stock -= quantity
            db.session.commit()
        return {"message": "Order created"}, 201
    except SQLAlchemyError as e:
        db.session.rollback()
        logger.error(f"Transaction failed: {str(e)}")
        raise

@app.route('/order/create', methods=['POST'])
def create_order():
    data = request.json
    try:
        result = process_order(data['product_id'], data['quantity'])
        return result
    except Exception as e:
        return {"error": str(e)}, 500

修复后，API 成功率从 80% 提升到 99.5%，死锁几乎消失，高峰期响应时间稳定在 250ms 内。这次 debug 让我对数据库事务和并发控制有了更深的理解，生产环境真是个大坑，但踩完感觉倍儿爽！

Flask API 数据库死锁的排查与解决

TDP会员

数据库

后端

运维

Flask电商API高并发死锁解决方案：统一多表锁顺序+索引优化+重试机制。通过固定Order-Inventory锁表顺序、添加product_id索引、引入tenacity重试库，将死锁问题从20%降至0.5%，响应时间稳定250ms内。分享MySQL死锁排查技巧与生产环境避坑经验。

MySQL

云数据库采购特惠，高性能、高可靠、高安全，超值优惠等你享！


AI驱动 智领未来

tencentdb-catalog

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

Flask API 数据库死锁的排查与解决

Flask API 数据库死锁的排查与解决

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐