你如何从 SQLAlchemy 控制 MySQL 超时？

Question

在使用 SQLAlchemy 对 MySQL 数据库运行时，从客户端控制超时的正确方法是什么？ connect_timeout URL 参数似乎不够用。

我更感兴趣的是当运行数据库的机器（例如，意外从网络中消失）时会发生什么。我不担心查询本身花费太长时间。

如果 somehost 不可用 在 到达 while 循环之前，以下脚本会执行您所期望的操作（即，大约一秒后超时）。但是如果 somehost 在while 循环中在 期间出现故障（例如，尝试在循环开始后拔出其网络电缆），那么超时似乎至少需要 18秒。是否缺少一些其他设置或参数？

wait_timeout 会话变量不起作用并不奇怪，因为我认为这是一个服务器端变量。但我把它扔在那里只是为了确保。

from sqlalchemy import *
from sqlalchemy.exc import *
import time
import sys

engine = create_engine("mysql://user:password@somehost/test?connect_timeout=1")
try:
    engine.execute("set session wait_timeout = 1;")
    while True:
        t = time.time()
        print t
        engine.execute("show tables;")
except DBAPIError:
    pass
finally:
    print time.time() - t, "seconds to time out"

Answer 1

这可能是 mysql/python 连接器中的错误吗？ https://bugs.launchpad.net/myconnpy/+bug/328998 这表示超时被硬编码为 10 秒。

要真正了解故障所在，您可以使用数据包嗅探器来检查服务器和客户端之间的对话。 wireshark + tcpdump 非常适合这种事情。

Answer 2

我相信你遇到了一个完全不同的错误，这是一个可怕的“mysql 已经消失”错误，如果我是对的，解决方案是更新到更新的 mysqldb 驱动程序，因为该错误已在驱动程序中修补。

如果由于某种原因您无法/不会更新，您应该为此尝试 SA 修复

db= create_engine('mysql://root@localhost/test', pool_recycle=True) 

Answer 3

由于 TCP 的工作方式，这是不可能的。如果另一台计算机掉线，它将停止响应传入的数据包。您看到的“18 秒”是由于没有响应而导致 TCP 堆栈超时。

获得所需行为的唯一方法是让计算机在死机前立即生成“我快死了”的消息。如果死亡是意料之外的，那是完全不可能的。

你听说过心跳吗？这些是高可用性系统每隔一秒或更短时间互相发送的数据包，让对方知道它们仍然存在。如果您希望您的应用程序“立即”知道服务器已消失，您首先必须确定“立即”有多长时间（1 秒、200 毫秒等），然后设计一个系统（例如心跳）来检测何时另一个系统不再存在。