Skip to content

Commit 19ff14e

Browse files
committed
chore: 新版redis库已支持异步,替换aioredis为redis
1 parent 94e9b47 commit 19ff14e

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

dash-fastapi-backend/config/get_redis.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
import aioredis
1+
from redis import asyncio as aioredis
2+
from redis.exceptions import AuthenticationError, TimeoutError, RedisError
23
from module_admin.service.dict_service import DictDataService
34
from module_admin.service.config_service import ConfigService
45
from config.env import RedisConfig
@@ -27,7 +28,18 @@ async def create_redis_pool(cls) -> aioredis.Redis:
2728
encoding="utf-8",
2829
decode_responses=True
2930
)
30-
logger.info("redis连接成功")
31+
try:
32+
connection = await redis.ping()
33+
if connection:
34+
logger.info("redis连接成功")
35+
else:
36+
logger.error("redis连接失败")
37+
except AuthenticationError as e:
38+
logger.error(f"redis用户名或密码错误,详细错误信息:{e}")
39+
except TimeoutError as e:
40+
logger.error(f"redis连接超时,详细错误信息:{e}")
41+
except RedisError as e:
42+
logger.error(f"redis连接错误,详细错误信息:{e}")
3143
return redis
3244

3345
@classmethod

0 commit comments

Comments
 (0)