-----Original Message-----
From:
twisted-python-bounces@twistedmatrix.com [mailto:
twisted-python-bounces@twistedmatrix.com] On Behalf Of Werner Thie
Sent: Tuesday, July 21, 2009 4:05 PM
To: Twisted general discussion
Subject: Re: [Twisted-Python] OT - adbapi, connection timeouts, mysql - OT
Hi Gabriel
had the same problem, solved it by having keepalive() called in a
LoopingCall(), MySQL sitting at defaults timingwise.
DB_DRIVER = "MySQLdb"
USERDB_ARGS = {
'host': '',
'db': '',
'user': '',
'passwd': '',
'cp_reconnect': True
}
storekeeper = StoreKeeper(DB_DRIVER, **USERDB_ARGS)
ka = task.LoopingCall(storekeeper.store.keepAlive)
ka.start(300)
class StoreKeeper(object):
def __init__(self, dbapiName, **params):
self.store = Store(dbapiName, **params)
def dbdisconn(self, reason):
print 'db disconnected for ', reason
def keepAlive(self):
d = self.store.runQuery('SELECT 1')
d.addErrback(self.dbdisconn)
#with store being something like:
class Store(object):
def __init__(self, dbapiName, **params):
self.__pool = adbapi.ConnectionPool(dbapiName, **params)
print self.__pool.__getstate__()
self.runOperation('SET autocommit = %s', 1)
def runQuery(self, query, *args):
d = self.__pool.runInteraction(self.mapQuery, query, args)
return d
def mapQuery(self, curs, query, *args):
try:
curs.execute(query, *args)
except adbapi.ConnectionLost:
print
print '++++++++++++ rerunning query'
print
curs.execute(query, *args) #simply resend
query, assuming cp_reconnect=True
result = curs.fetchall()
columns = [d[0] for d in curs.description]
return [dict(zip(columns, r)) for r in result]
def runOperation(self, query, *args):
d = self.__pool.runOperation(query, args)
return d
def runInteraction(self, fun, queries=(), args=()):
d = self.__pool.runInteraction(fun, queries, args)
return d
HTH, Werner
Gabriel Rossetti wrote:
> Hello everyone,
>
> I have been experiencing the ConnectionError with adbapi &
> cp_reconnect=True. I know that because of the cp_reconnect=True param
> tha is reconnects and that the query is not re-run. I have written some
> code that should re-run the query in that case (if I get a Failure back
> because of a ConnectionError), but it doesn't seem to work. My question
> is if anyone knows how to make mysql's idle timeouts shorter so that I
> can debug my code? I searched google and the mysql site with no luck.
>
> thank you,
> Gabriel
>
> _______________________________________________
> Twisted-Python mailing list
>
Twisted-Python@twistedmatrix.com
>
http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python
_______________________________________________
Twisted-Python mailing list
Twisted-Python@twistedmatrix.com
http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python