通过副本端点读取数据

Controller/InitController.py

@@ -65,7 +65,8 @@ class InitView(View):
                 ssl_cert_reqs=None
             )
             redis_client.set(key, value)
-            redis_value = redis_client.get(key)
+            redis_r_obj = RedisObject(mode='r')
+            redis_value = redis_r_obj.get_data(key)
             res = {
                 'redis_value': redis_value
             }
@@ -96,8 +97,10 @@ class InitView(View):
             equipment_info_value = json.dumps(equipment_info_kwargs)
             equipment_info_key = 'equipment_info'
             redis_obj.rpush(equipment_info_key, equipment_info_value)
-            equipment_info_redis_list = redis_obj.lrange(equipment_info_key, 0, 99)
-            redis_obj.ltrim(equipment_info_key, 100, -1)
+
+            redis_r_obj = RedisObject(mode='r')
+            equipment_info_redis_list = redis_r_obj.lrange(equipment_info_key, 0, 99)
+            redis_r_obj.ltrim(equipment_info_key, 100, -1)
 
             equipment_info_list = []
             for equipment_info in equipment_info_redis_list:

Object/RedisObject.py

@@ -9,17 +9,21 @@ from AnsjerPush.config import REDIS_ADDRESS, CONFIG_INFO, CONFIG_US
 
 class RedisObject:
 
-    def __init__(self, db=0):
+    def __init__(self, mode='w', 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.POOL = redis.ConnectionPool(connection_class=SSLConnection, host=REDIS_ADDRESS, port=6379, db=db)
+            if mode == 'w':
+                host = REDIS_ADDRESS
+            else:
+                host = 'amaaaaaayszequiamxr7cdpparig3ptmytvde5vvnz6n7gceo4232sbhhlsa-r.redis.us-phoenix-1.oci.oraclecloud.com'
+            self.POOL = redis.ConnectionPool(connection_class=SSLConnection, host=host, port=6379, db=db)
             self.CONN = redis.StrictRedis(
                 connection_pool=self.POOL,
-                host=REDIS_ADDRESS,
+                host=host,
                 ssl=True,
                 ssl_cert_reqs=None,
             )