|
@@ -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:
|