From 6dba8079e8083d829d012ab3c00c83aa1de051a7 Mon Sep 17 00:00:00 2001 From: weihe0720 Date: Mon, 20 Apr 2026 23:38:57 +0800 Subject: [PATCH] =?UTF-8?q?fix(redis=5Fcrud):=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=93=88=E5=B8=8C=E6=93=8D=E4=BD=9C=E6=96=B9=E6=B3=95=E6=9C=AA?= =?UTF-8?q?=E6=AD=A3=E7=A1=AE=E4=BD=BF=E7=94=A8await=E7=9A=84=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 移除hash_get方法返回类型中错误的Awaitable联合类型，并确保hash_set和hash_get方法内部正确使用await调用Redis客户端方法，以支持异步操作。 --- backend/app/core/redis_crud.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/backend/app/core/redis_crud.py b/backend/app/core/redis_crud.py index 0ced6758..4754e00e 100644 --- a/backend/app/core/redis_crud.py +++ b/backend/app/core/redis_crud.py @@ -1,5 +1,4 @@ import json -from collections.abc import Awaitable from typing import Any from redis.asyncio.client import Redis @@ -319,13 +318,13 @@ class RedisCURD: - bool: 如果设置哈希缓存成功则返回True,否则返回False """ try: - self.redis.hset(name=name, key=key, value=value) + await self.redis.hset(name=name, key=key, value=value) return True except Exception as e: log.error(f"设置哈希缓存失败: {e!s}") return False - async def hash_get(self, name: str, keys: list[str]) -> Awaitable[list[Any]] | list[Any]: + async def hash_get(self, name: str, keys: list[str]) -> list[Any]: """获取哈希缓存 参数: @@ -336,7 +335,7 @@ class RedisCURD: - Awaitable[list[Any]] | list[Any]: 返回哈希缓存值列表,如果获取失败则返回空列表 """ try: - data = self.redis.hmget(name=name, keys=keys) + data = await self.redis.hmget(name=name, keys=keys) return data except Exception as e: log.error(f"获取哈希缓存失败: {e!s}")