Wie kann ich gepoolte Verbindungen in SQLAlchemy prüfen, bevor ich sie an meinen Anwendungscode weitergebe?

Question

Wir haben einen leicht unzuverlässigen Datenbankserver, aus verschiedenen Gründen, und als Konsequenz verschwinden manchmal die Datenbankverbindungen, die von meiner Anwendung verwendet werden. Die Verbindungen sind SQLAlchemy 0.6.5-Verbindungen zu einer PostgreSQL-Datenbank in einer Pylons 1.0-Weblaufzeitumgebung.

Was ich will, ist eine Möglichkeit, am meisten von diesen ohne einen Benutzer sichtbaren Fehler zu fangen; Idealerweise würde ich die Verbindung auf der Poolebene testen, bevor ich sie von der Engine zurückbringe. Ich kontrolliere die Erstellung des Motors, also bin ich okay.

Was ist die beste (idomatic/cleanest) Weise, dies zu erreichen? Ich weiß, dass es immer die Möglichkeit geben wird, dass die Verbindung zwischen der Kontrolle und der Nutzung abbricht, aber das wird in dieser Umgebung ziemlich selten sein und ist daher für mich kein Problem.

Answer 1

Sie könnten einen Pool Hörer verwenden:

class ConnectionChecker(sqlalchemy.interfaces.PoolListener): 
    def checkout(self, dbapi_con, con_record, con_proxy): 
     if not is_valid_connection(dbapi_con): 
      # a new connection will be used 
      raise sqlalchemy.exc.DisconnectionError 

links für Sie ist, wie is_valid_connection für Ihren Anwendungsfall zu implementieren.