|
@ -1,4 +1,5 @@ |
|
|
import aioredis |
|
|
from redis import asyncio as aioredis |
|
|
|
|
|
from redis.exceptions import AuthenticationError, TimeoutError, RedisError |
|
|
from module_admin.service.dict_service import DictDataService |
|
|
from module_admin.service.dict_service import DictDataService |
|
|
from module_admin.service.config_service import ConfigService |
|
|
from module_admin.service.config_service import ConfigService |
|
|
from config.env import RedisConfig |
|
|
from config.env import RedisConfig |
|
@ -27,7 +28,18 @@ class RedisUtil: |
|
|
encoding="utf-8", |
|
|
encoding="utf-8", |
|
|
decode_responses=True |
|
|
decode_responses=True |
|
|
) |
|
|
) |
|
|
|
|
|
try: |
|
|
|
|
|
connection = await redis.ping() |
|
|
|
|
|
if connection: |
|
|
logger.info("redis连接成功") |
|
|
logger.info("redis连接成功") |
|
|
|
|
|
else: |
|
|
|
|
|
logger.error("redis连接失败") |
|
|
|
|
|
except AuthenticationError as e: |
|
|
|
|
|
logger.error(f"redis用户名或密码错误,详细错误信息:{e}") |
|
|
|
|
|
except TimeoutError as e: |
|
|
|
|
|
logger.error(f"redis连接超时,详细错误信息:{e}") |
|
|
|
|
|
except RedisError as e: |
|
|
|
|
|
logger.error(f"redis连接错误,详细错误信息:{e}") |
|
|
return redis |
|
|
return redis |
|
|
|
|
|
|
|
|
@classmethod |
|
|
@classmethod |
|
|