2

我正在使用一个 Python 脚本，它对我们的外发邮件消息进行一定的流量控制，主要检查用户是否发送垃圾邮件。

该脚本通过SQLObject. 在某些情况下，连接被第三方丢弃（例如，我们的防火墙由于空闲过多而关闭了连接），并且SQLObject没有注意到它已被关闭并继续在死的 TCP 处理程序上发送查询，从而导致日志像这样的条目：

Feb 06 06:56:07 mailsrv2 flow: ERROR Processing request error: [Failure instance: Traceback: <class 'psycopg2.InterfaceError'>: connection already closed#012/usr/lib/python2.7/threading.py:524:__bootstrap#012/usr/lib/python2.7/threading.py:551:__bootstrap_inner#012/usr/lib/python2.7/threading.py:504:run#012--- <exception caught here>---#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/twisted/python/threadpool.py:191:_worker#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/twisted/python/context.py:118:callWithContext#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/twisted/python/context.py:81:callWithContext#012
/opt/scripts/flow/server.py:91:check#012
/opt/scripts/flow/flow.py:252:check#012
/opt/scripts/flow/flow.py:155:append_to_log#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/main.py:1226:__init__#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/main.py:1274:_create#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/main.py:1298:_SO_finishCreate#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/dbconnection.py:468:queryInsertID#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/dbconnection.py:327:_runWithConnection#012
/opt/scripts/virtualenv/local/lib/python2.7/site-packages/SQLObject-1.3.1-py2.7.egg/sqlobject/postgres/pgconnection.py:191:_queryInsertID#012]

这让我觉得对于这种情况确实必须有一些回调，否则不会写入日志条目。我会使用该回调来建立与数据库的新连接。我一直找不到任何关于此的文档。

有谁知道是否有可能实现该回调以及如何声明它？

谢谢。

4

1 回答 1

3

我们是SQLAlchemy而不是SQLObject. 根据 2010 年的这个线程（http://sourceforge.net/p/sqlobject/mailman/message/26460439），SQLObject不支持 PostgreSQL 的重新连接逻辑。这是一个旧线程，但似乎没有任何关于从 SQLObject 中解决这个问题的讨论。

我有三个建议的解决方案。

第一个解决方案是探索连接池。当 SQLObject 检测到 psycopg2 已断开连接时，它可能会提供一种打开新连接对象的方法。我不能保证它会，但如果它这样做，这个解决方案将是你最好的，因为它需要你做的改动最少。

第二种解决方案是将后端从 Postgres 切换到 MySQL。SQLObject 文档提供了有关如何使用 mysql 驱动程序的重新连接逻辑的信息 - http://sourceforge.net/p/mysql-python/feature-requests/9

第三种解决方案是切换到 SQLAlchemy 作为 ORM 并使用他们的连接池版本。根据核心事件文档，使用池时，如果连接断开或关闭，将打开一个新连接——http: //docs.sqlalchemy.org/en/rel_0_9/core/exceptions.html#sqlalchemy.exc.DisconnectionError

祝你好运

于 2015-02-08T20:15:09.650 回答