释放redis连接回连接池

Controller/InitController.py

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

Object/RedisObject.py

@@ -17,7 +17,8 @@ class RedisObject:
                 host = OCI_REDIS_NODE_PRIMARY
             else:
                 host = OCI_REDIS_NODE_READ
-            self.POOL = redis.ConnectionPool(connection_class=SSLConnection, host=host, port=6379, db=db)
+            self.POOL = redis.ConnectionPool(connection_class=SSLConnection, host=host, port=6379, db=db,
+                                             max_connections=100)
             self.CONN = redis.StrictRedis(
                 connection_pool=self.POOL,
                 host=host,