|
@@ -1,21 +1,24 @@
|
|
|
-import redis,ssl
|
|
|
+import redis
|
|
|
from AnsjerPush.config import REDIS_ADDRESS, CONFIG_INFO, CONFIG_US
|
|
|
|
|
|
# 本地调试把注释打开
|
|
|
# REDIS_ADDRESS = '127.0.0.1'
|
|
|
|
|
|
+
|
|
|
class RedisObject:
|
|
|
|
|
|
def __init__(self, db=0):
|
|
|
- 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:
|
|
@@ -88,5 +91,3 @@ class RedisObject:
|
|
|
@return : bool
|
|
|
"""
|
|
|
return self.CONN.lindex(name, index)
|
|
|
-
|
|
|
-RedisObject_OCL = RedisObject
|