|
|
|
|
26
|
def connect_redis():
|
26
|
def connect_redis():
|
27
|
return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
|
27
|
return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
|
28
|
r'''
|
28
|
r'''
|
|
|
29
|
+
|
29
|
return {
|
30
|
return {
|
30
|
"rconn0":redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
|
31
|
"rconn0":redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
|
31
|
"rconn1":redis.Redis(host='localhost', port=6379, db=1,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
|
32
|
"rconn1":redis.Redis(host='localhost', port=6379, db=1,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace"),
|
|
|
|
|
175
|
# for now we are not going to do any weird class stuff
|
176
|
# for now we are not going to do any weird class stuff
|
176
|
self.acl = None
|
177
|
self.acl = None
|
177
|
self.has_cl = False
|
178
|
self.has_cl = False
|
178
|
- # rconns = connect_redis()
|
|
|
|
|
179
|
+ rconns = connect_redis()
|
179
|
self.rconn = connect_redis()
|
180
|
self.rconn = connect_redis()
|
180
|
self.rman = RldMan()
|
181
|
self.rman = RldMan()
|
181
|
self.cbs_once = []
|
182
|
self.cbs_once = []
|