This commit is contained in:
jxxghp
2025-09-08 12:12:00 +08:00
parent 5bd210406b
commit 1e94d794ed
2 changed files with 6 additions and 6 deletions
+3 -3
View File
@@ -455,7 +455,7 @@ class MemoryBackend(CacheBackend):
if region_cache: if region_cache:
with lock: with lock:
region_cache.clear() region_cache.clear()
logger.info(f"Cleared cache for region: {region}") logger.debug(f"Cleared cache for region: {region}")
else: else:
# 清除所有区域的缓存 # 清除所有区域的缓存
for region_cache in self._region_caches.values(): for region_cache in self._region_caches.values():
@@ -589,13 +589,13 @@ class AsyncMemoryBackend(AsyncCacheBackend):
if region_cache: if region_cache:
with lock: with lock:
region_cache.clear() region_cache.clear()
logger.info(f"Cleared cache for region: {region}") logger.debug(f"Cleared cache for region: {region}")
else: else:
# 清除所有区域的缓存 # 清除所有区域的缓存
for region_cache in self._region_caches.values(): for region_cache in self._region_caches.values():
with lock: with lock:
region_cache.clear() region_cache.clear()
logger.info("Cleared all cache") logger.info("All cache cleared")
async def items(self, region: Optional[str] = DEFAULT_CACHE_REGION) -> AsyncGenerator[Tuple[str, Any], None]: async def items(self, region: Optional[str] = DEFAULT_CACHE_REGION) -> AsyncGenerator[Tuple[str, Any], None]:
""" """
+3 -3
View File
@@ -258,10 +258,10 @@ class RedisHelper(metaclass=Singleton):
for key in self.client.scan_iter(redis_key): for key in self.client.scan_iter(redis_key):
pipe.delete(key) pipe.delete(key)
pipe.execute() pipe.execute()
logger.info(f"Cleared Redis cache for region: {region}") logger.debug(f"Cleared Redis cache for region: {region}")
else: else:
self.client.flushdb() self.client.flushdb()
logger.info("Cleared all Redis cache") logger.info("All Redis cache Cleared")
except Exception as e: except Exception as e:
logger.error(f"Failed to clear cache, region: {region}, error: {e}") logger.error(f"Failed to clear cache, region: {region}, error: {e}")
@@ -496,7 +496,7 @@ class AsyncRedisHelper(metaclass=Singleton):
async for key in self.client.scan_iter(redis_key): async for key in self.client.scan_iter(redis_key):
await pipe.delete(key) await pipe.delete(key)
await pipe.execute() await pipe.execute()
logger.info(f"Cleared Redis cache for region (async): {region}") logger.debug(f"Cleared Redis cache for region (async): {region}")
else: else:
await self.client.flushdb() await self.client.flushdb()
logger.info("Cleared all Redis cache (async)") logger.info("Cleared all Redis cache (async)")