|
@@ -8,17 +8,17 @@ from AnsjerPush.config import REDIS_ADDRESS, CONFIG_INFO, CONFIG_US
|
|
|
class RedisObject:
|
|
|
|
|
|
def __init__(self, db=0):
|
|
|
- self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
|
|
|
- self.CONN = redis.Redis(connection_pool=self.POOL)
|
|
|
- # if CONFIG_INFO != CONFIG_US:
|
|
|
- # self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
|
|
|
- # self.CONN = redis.Redis(connection_pool=self.POOL)
|
|
|
- # else:
|
|
|
- # self.CONN = redis.StrictRedis(
|
|
|
- # host=REDIS_ADDRESS,
|
|
|
- # ssl=True,
|
|
|
- # ssl_cert_reqs=None,
|
|
|
- # )
|
|
|
+ # self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
|
|
|
+ # self.CONN = redis.Redis(connection_pool=self.POOL)
|
|
|
+ if CONFIG_INFO != CONFIG_US:
|
|
|
+ self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
|
|
|
+ self.CONN = redis.Redis(connection_pool=self.POOL)
|
|
|
+ else:
|
|
|
+ self.CONN = redis.StrictRedis(
|
|
|
+ host=REDIS_ADDRESS,
|
|
|
+ ssl=True,
|
|
|
+ ssl_cert_reqs=None,
|
|
|
+ )
|
|
|
|
|
|
def set_data(self, key, val, expire=0):
|
|
|
try:
|