discours.io/inbox
5
0
Fork 0
Code Pull Requests Actions Wiki Activity

redis-multi-exec-fix-2

Browse Source
This commit is contained in:
Untone 2023-10-13 11:36:44 +03:00
parent dbf3d1c745
commit 25e05381cb
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
services/redis.py
View File

@ -11,6 +11,8 @@ class RedisCache:
async def connect(self): async def connect(self):
self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True) self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True)
response = await self._redis.execute('PING')
print(f"[redis] PING response: {response}")
async def disconnect(self): async def disconnect(self):
self._redis.connection_pool.disconnect() self._redis.connection_pool.disconnect()
@ -52,9 +54,6 @@ class RedisCache:
print(f"[redis] MGET {key} {keys}") print(f"[redis] MGET {key} {keys}")
return await self._redis.mget(key, *keys) return await self._redis.mget(key, *keys)
async def pipeline(self):
print(f"[redis] pipeline")
return await self._redis.pipeline()
redis = RedisCache() redis = RedisCache()