Przeglądaj źródła

oci redis使用连接池3

locky 1 rok temu
rodzic
commit
af162f0418
1 zmienionych plików z 3 dodań i 1 usunięć
  1. 3 1
      Object/RedisObject.py

+ 3 - 1
Object/RedisObject.py

@@ -1,4 +1,6 @@
 import redis
+from redis.connection import SSLConnection
+
 from AnsjerPush.config import REDIS_ADDRESS, CONFIG_INFO, CONFIG_US
 
 # 本地调试把注释打开
@@ -14,7 +16,7 @@ class RedisObject:
             self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
             self.CONN = redis.Redis(connection_pool=self.POOL)
         else:
-            self.POOL = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
+            self.POOL = redis.ConnectionPool(connection_class=SSLConnection, host=REDIS_ADDRESS, port=6379, db=db)
             self.CONN = redis.StrictRedis(
                 connection_pool=self.POOL,
                 host=REDIS_ADDRESS,