Docker部署Flask项目后数据过滤失效问题求助

问题背景 #

我已将Flask项目Docker化，项目通过接收added_at时间参数过滤产品数据。本地环境中添加产品后搜索可正常返回新数据，但Docker环境下出现异常：手动向MySQL添加记录后，搜索无法立即获取新数据，重启app服务或等待数小时后才会正常返回结果，疑似数据库与应用存在同步延迟。

核心代码 #

def post(self):
    args = request.get_json()
    products = Product.query

    args = {k: v for k, v in args.items() if v}
    
    added_at = args['added_at'] if 'added_at' in args else datetime.now() - timedelta(days=7)
    products = products.filter(Product.created_at >= added_at).all()

    return len(products), 200

复现步骤 #

• 执行docker-compose up -d启动服务
• 手动向MySQL数据库添加一条记录
• 搜索产品时无法返回新添加的记录（即使created_at为昨日时间）
• 重启app服务后，搜索可正常返回新记录

Docker Compose配置（app服务部分） #

version: '3.7'
services:
  app:
    build: .
    container_name: app
    image: app
    tty: true
    volumes:
      - .:/app
    depends_on:
      - db
    ports:
        - "8000:8000"
    networks:
      - app-network

排查与解决方法 #

1. 会话缓存未刷新 #

Flask-SQLAlchemy默认会复用数据库会话，会话内会缓存查询结果，导致新添加的数据无法实时被读取。解决方法是在查询前强制刷新会话缓存：

def post(self):
    args = request.get_json()
    # 强制清除会话缓存，确保读取最新数据
    db.session.expire_all()
    
    products = Product.query
    args = {k: v for k, v in args.items() if v}
    
    added_at = args['added_at'] if 'added_at' in args else datetime.now() - timedelta(days=7)
    products = products.filter(Product.created_at >= added_at).all()

    return len(products), 200

2. 事务隔离级别问题 #

MySQL默认隔离级别为REPEATABLE READ，同一事务内的查询会读取固定快照，无法看到其他事务提交的新数据。如果Docker环境中应用长期持有同一个事务，就会出现延迟。可以临时调整会话隔离级别：

from sqlalchemy import text

def post(self):
    args = request.get_json()
    
    # 将当前会话隔离级别设为READ COMMITTED，确保读取最新提交的数据
    db.session.execute(text("SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED"))
    db.session.commit()
    
    products = Product.query
    args = {k: v for k, v in args.items() if v}
    
    added_at = args['added_at'] if 'added_at' in args else datetime.now() - timedelta(days=7)
    products = products.filter(Product.created_at >= added_at).all()

    return len(products), 200

3. 查询缓存复用问题 #

SQLAlchemy会缓存查询结果，若复用了查询对象可能导致旧数据被返回。可以强制每次查询使用新会话：

# 用with_session确保查询使用当前最新会话
products = Product.query.with_session(db.session).filter(Product.created_at >= added_at).all()

4. 时区不一致问题 #

检查Docker容器与MySQL的时区是否一致，时区偏移会导致added_at计算错误，过滤掉符合条件的新数据：

• 在Dockerfile中设置容器时区：

RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
RUN echo "Asia/Shanghai" > /etc/timezone

• 建议统一使用UTC时间存储和查询，将datetime.now()替换为datetime.utcnow()，避免时区差异。

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