From 8c33955d5ca84c8752cbe65316f61f69793ab469 Mon Sep 17 00:00:00 2001 From: Untone Date: Wed, 24 Jan 2024 15:36:34 +0300 Subject: [PATCH] redis-service-fix --- services/rediscache.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/services/rediscache.py b/services/rediscache.py index 582de65b..2695ebb6 100644 --- a/services/rediscache.py +++ b/services/rediscache.py @@ -1,6 +1,10 @@ import redis.asyncio as aredis from settings import REDIS_URL +import logging + +logger = logging.getLogger("[services.redis] ") +logger.setLevel(logging.DEBUG) class RedisCache: @@ -19,12 +23,13 @@ class RedisCache: async def execute(self, command, *args, **kwargs): if self._client: try: - print("[redis] " + command + " " + " ".join(args)) + logger.debug(f"{command} {args} {kwargs}") r = await self._client.execute_command(command, *args, **kwargs) + logger.debug(type(r)) + logger.debug(r) return r except Exception as e: - print(f"[redis] error: {e}") - return None + logger.error(e) async def subscribe(self, *channels): if self._client: @@ -46,7 +51,6 @@ class RedisCache: return await self._client.publish(channel, data) - redis = RedisCache() __all__ = ["redis"]