|
@@ -1,14 +1,21 @@
|
|
|
-import redis
|
|
|
-from AnsjerPush.config import REDIS_ADDRESS
|
|
|
+import redis,ssl
|
|
|
+from AnsjerPush.config import REDIS_ADDRESS, REDIS_ADDRESS_OCI, CONFIG_INFO, CONFIG_US
|
|
|
+
|
|
|
# 本地调试把注释打开
|
|
|
# REDIS_ADDRESS = '127.0.0.1'
|
|
|
|
|
|
-
|
|
|
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_OCI,
|
|
|
+ ssl=True,
|
|
|
+ ssl_cert_reqs=None,
|
|
|
+ )
|
|
|
|
|
|
def set_data(self, key, val, expire=0):
|
|
|
try:
|
|
@@ -72,3 +79,5 @@ class RedisObject:
|
|
|
@return : bool
|
|
|
"""
|
|
|
return self.CONN.ltrim(name, start, end)
|
|
|
+
|
|
|
+RedisObject_OCL = RedisObject
|