高端上海网站设计公司价格,怎么在线更新wordpress,深圳有做网站公司,3d建模在线制作网站在 psycopg2 中#xff0c;验证数据库连接是否有效#xff08;即连接是否仍然活跃#xff09;可以通过以下几种方法实现#xff1a;1. 使用 conn.closed 属性
psycopg2 的连接对象有一个 closed 属性#xff0c;可以检查连接是否已关闭#xff1a;
import psycopg2conn …在 psycopg2 中验证数据库连接是否有效即连接是否仍然活跃可以通过以下几种方法实现1. 使用 conn.closed 属性
psycopg2 的连接对象有一个 closed 属性可以检查连接是否已关闭
import psycopg2conn psycopg2.connect(hostlocalhost,databasetestdb,userpostgres,passwordyour_password
)# 检查连接是否关闭
if conn.closed:print(连接已关闭)
else:print(连接仍然有效)conn.close()问题closed 只能检测连接是否被显式关闭无法检测连接是否因网络问题或数据库超时而失效。2. 执行简单查询推荐
最可靠的方法是 执行一个简单的 SQL 查询如 SELECT 1如果查询失败则说明连接已断开
def is_connection_valid(conn):try:cursor conn.cursor()cursor.execute(SELECT 1) # 执行简单查询cursor.fetchone() # 获取结果可选cursor.close()return True # 查询成功连接有效except (psycopg2.Error, psycopg2.OperationalError):return False # 查询失败连接已断开# 使用示例
if is_connection_valid(conn):print(连接有效)
else:print(连接已断开需要重新连接)conn psycopg2.connect(...) # 重新建立连接优点
能检测 网络中断、数据库超时、连接被服务器关闭 等情况。适用于连接池如 ThreadedConnectionPool中的连接健康检查。3. 使用 conn.poll() 方法适用于异步检查
psycopg2 提供了 conn.poll() 方法可以检查连接状态
def is_connection_valid(conn):try:conn.poll() # 检查连接状态return Trueexcept psycopg2.OperationalError:return False说明
poll() 会返回连接状态如 psycopg2.extensions.POLL_OK、POLL_ERROR 等。但通常直接捕获异常更简单。4. 在连接池中验证连接
如果使用 ThreadedConnectionPool可以在 getconn() 后验证连接是否有效如果无效则重新创建
from psycopg2 import OperationalErrordef get_valid_connection(pool):conn pool.getconn()if not is_connection_valid(conn): # 使用前面的方法检查conn.close() # 关闭无效连接conn pool.getconn() # 尝试获取新连接return conn# 使用示例
conn get_valid_connection(pool)5. 设置 keepalives 参数预防连接断开
在连接字符串中设置 keepalives 参数让 PostgreSQL 服务器定期发送心跳包防止连接因空闲超时而断开
conn psycopg2.connect(hostlocalhost,databasetestdb,userpostgres,passwordyour_password,keepalives1, # 启用 TCP keepalivekeepalives_idle30, # 30秒空闲后发送心跳keepalives_interval10, # 每10秒发送一次心跳keepalives_count5 # 最多尝试5次
)适用场景
适用于长时间空闲的连接减少因网络问题导致的连接断开。总结方法适用场景备注conn.closed仅检查连接是否被显式关闭无法检测网络问题执行简单查询SELECT 1检测连接是否真正可用推荐方法conn.poll()异步检查连接状态较少使用连接池 验证在 ThreadedConnectionPool 中使用确保获取的连接有效keepalives 参数预防连接因空闲超时断开适用于长时间空闲连接最佳实践
在获取连接后先执行 SELECT 1 验证连接是否有效。如果连接无效关闭并重新获取连接避免连接池返回坏连接。设置 keepalives 参数减少空闲连接被断开的情况。
这样能确保你的应用在连接失效时自动恢复提高稳定性。
