测试oci redis集群

AnsjerPush/us_config/formal_config.py

@@ -20,7 +20,7 @@ SECRET_ACCESS_KEY = 'ckYLg4Lo9ZXJIcJEAKkzf2rWvs8Xth1FCjqiAqUw'
 PUSH_BUCKET = 'foreignpush'                                # 推送存储桶
 
 # redis节点
-REDIS_ADDRESS = 'pushredis.5tgle2.0001.usw1.cache.amazonaws.com'
+REDIS_ADDRESS = '10.60.1.113'
 
 APNS_MODE = 'prod'
 

Object/RedisObject.py

@@ -1,5 +1,5 @@
 import redis
-from AnsjerPush.config import REDIS_ADDRESS
+from AnsjerPush.config import REDIS_ADDRESS, CONFIG_INFO, CONFIG_US
 
 # 本地调试把注释打开
 # REDIS_ADDRESS = '127.0.0.1'
@@ -8,7 +8,11 @@ from AnsjerPush.config import REDIS_ADDRESS
 class RedisObject:
 
     def __init__(self, db=0):
-        pool = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
+        if CONFIG_INFO == CONFIG_US:
+            password = '012bzaKUhleHc2645465'
+            pool = redis.ConnectionPool(host=REDIS_ADDRESS, password=password, port=6379, db=db)
+        else:
+            pool = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
         self.CONN = redis.Redis(connection_pool=pool)
 
     def set_data(self, key, val, expire=0):