소스 검색

修改redis对象初始化

locky 1 년 전
부모
커밋
7ac8d3f7a6
1개의 변경된 파일3개의 추가작업 그리고 2개의 파일을 삭제
  1. 3 2
      Object/RedisObject.py

+ 3 - 2
Object/RedisObject.py

@@ -10,10 +10,11 @@ class RedisObject:
     def __init__(self, db=0):
         if CONFIG_INFO == CONFIG_US:
             password = '012bzaKUhleHc2645465'
-            pool = redis.ConnectionPool(host=REDIS_ADDRESS, password=password, port=6379, db=db)
+            pool = redis.ConnectionPool()
+            self.CONN = redis.Redis(host=REDIS_ADDRESS, password=password, port=6379, db=db, connection_pool=pool)
         else:
             pool = redis.ConnectionPool(host=REDIS_ADDRESS, port=6379, db=db)
-        self.CONN = redis.Redis(connection_pool=pool)
+            self.CONN = redis.Redis(connection_pool=pool)
 
     def set_data(self, key, val, expire=0):
         self.CONN.set(key, val)