This commit is contained in:
erbalito
2019-02-21 08:39:41 -03:00
committed by GitHub
parent f06c60b963
commit df2d09706c
+4 -2
View File
@@ -29,14 +29,16 @@ except ImportError:
locker = Lock() locker = Lock()
def RConn(*args, **vars): def RConn(application=None, *args, **vars):
""" """
Istantiates a StrictRedis connection with parameters, at the first time Istantiates a StrictRedis connection with parameters, at the first time
only only
""" """
locker.acquire() locker.acquire()
try: try:
instance_name = 'redis_conn_' + current.request.application if application is None:
application = current.request.application
instance_name = 'redis_conn_' + application
if not hasattr(RConn, instance_name): if not hasattr(RConn, instance_name):
setattr(RConn, instance_name, redis.StrictRedis(*args, **vars)) setattr(RConn, instance_name, redis.StrictRedis(*args, **vars))
return getattr(RConn, instance_name) return getattr(RConn, instance_name)