@@ -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)
|
||||||
|
|||||||
Reference in New Issue
Block a user