Flask-Session+Redis Sentinel集群：主节点切换后应用崩溃问题

核心问题分析 #

你遇到的问题本质是Flask Session使用的Redis客户端没有自动感知Sentinel的主节点切换，硬编码或静态配置的主节点连接在故障后无法自动更新，导致后续请求落到旧主（已变从库，只读）或超时。

具体解决步骤 #

1. 使用支持Sentinel自动发现的Redis连接池 #

放弃手动指定主节点地址，改用redis-py的SentinelConnectionPool，它会定期向Sentinel集群查询当前主节点，自动处理故障转移。

示例代码（初始化Flask-Session）：

from redis.sentinel import Sentinel
from flask import Flask
from flask_session import Session

app = Flask(__name__)

# 初始化Sentinel客户端（替换为你的Sentinel集群地址，K8s中建议用Service域名）
sentinel = Sentinel(
    [("sentinel-service", 26379)],
    socket_timeout=0.1,
    socket_connect_timeout=0.1
)

# 通过Sentinel获取主节点的连接池（无需指定具体主节点IP）
master_pool = sentinel.master_for(
    "mymaster",  # 你的Redis主节点名称
    socket_timeout=0.1,
    db=0,
    password="your-redis-password"  # 如有密码请添加
)

# 配置Flask-Session使用该连接池
app.config["SESSION_TYPE"] = "redis"
app.config["SESSION_REDIS"] = master_pool
app.config["SESSION_PERMANENT"] = False
Session(app)

这样配置后，redis-py会自动维护当前主节点的连接，故障转移后无需手动修改配置。

2. 捕获Redis异常并强制刷新连接池 #

如果已经上线的代码无法立刻切换连接池，可以通过错误捕获机制，在遇到Redis连接超时或只读错误时，重新获取主节点连接：

from redis.exceptions import ConnectionError, ReadOnlyError
from flask import redirect, request

@app.errorhandler(ConnectionError)
@app.errorhandler(ReadOnlyError)
def refresh_redis_connection(e):
    # 重新初始化主节点连接池
    global master_pool
    master_pool = sentinel.master_for("mymaster", socket_timeout=0.1, db=0)
    # 更新Flask-Session的Redis连接实例
    app.session_interface.redis = master_pool
    # 重定向到当前请求（让用户重试，保留原请求方法和数据）
    return redirect(request.url, code=307)

注意：Gunicorn多worker模式下，每个worker是独立进程，所以每个worker需要各自触发一次错误才能更新本地的连接池，但这比手动重启worker更平滑。

3. K8s环境下的兜底方案 #

如果上述方法仍有遗漏，可通过K8s的探针机制实现自动故障恢复：

• Liveness探针：编写一个简单的接口，尝试向Redis主节点写入测试Key，若失败则触发worker重启。
• 滚动重启：若需要批量更新worker，执行kubectl rollout restart deployment <your-deployment>，K8s会逐个重启worker，避免服务中断。

是否需要重启Gunicorn worker？ #

重启worker确实能解决问题，但会导致当前请求中断，影响用户体验。优先用前两种自动切换方案，只有在极端场景（比如客户端连接池存在bug）下，才考虑用K8s滚动重启作为兜底。

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