blob: fb9ff81424d957e9ba422ae1f82df88bdc274cd8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
import os
from redis.asyncio import ConnectionPool, Redis
class RedisConnectionPool:
_pool: ConnectionPool | None = None
@classmethod
def get_connection(cls) -> Redis:
if cls._pool is None:
cls._pool = ConnectionPool.from_url(os.environ.get('REDIS_URL'))
return Redis(connection_pool=cls._pool)
|
