From bf5c0af9d084838dfab9f592c04c84649e5e6f18 Mon Sep 17 00:00:00 2001
From: fit2cloud-chenyw <yawen.chen@fit2cloud.com>
Date: Fri, 18 Jul 2025 11:11:57 +0800
Subject: [PATCH] perf: cache log

---
 backend/common/core/sqlbot_cache.py | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git a/backend/common/core/sqlbot_cache.py b/backend/common/core/sqlbot_cache.py
index 0d32917b..93aeb27c 100644
--- a/backend/common/core/sqlbot_cache.py
+++ b/backend/common/core/sqlbot_cache.py
@@ -1,13 +1,12 @@
+import logging
 from fastapi_cache import FastAPICache
 from fastapi_cache.decorator import cache as original_cache
 from functools import partial, wraps
 from typing import Optional, Set, Any, Dict, Tuple, Callable
 from inspect import Parameter, signature
-import logging
 from contextlib import asynccontextmanager
 import asyncio
 
-logger = logging.getLogger(__name__)
 
 # 锁管理
 _cache_locks = {}
@@ -66,7 +65,7 @@ def custom_key_builder(
                     base_key += f"{value}:"
                 
             except (IndexError, KeyError, AttributeError) as e:
-                logger.warning(f"Failed to evaluate keyExpression '{keyExpression}': {str(e)}")
+                logging.warning(f"Failed to evaluate keyExpression '{keyExpression}': {str(e)}")
         
         return base_key
     
@@ -128,13 +127,19 @@ def cache(
             )
             
             async with _get_cache_lock(cache_key):
+                logging.info(f"Using cache key: {cache_key}")
+                print(f"Using cache key: {cache_key}")
                 backend = FastAPICache.get_backend()
                 cached_value = await backend.get(cache_key)
                 if cached_value is not None:
+                    logging.info(f"Cache hit for key: {cache_key}, the value is: {cached_value}")
+                    print(f"Cache hit for key: {cache_key}, the value is: {cached_value}")
                     return cached_value
                 
                 result = await func(*args, **kwargs)
                 await backend.set(cache_key, result, expire)
+                logging.info(f"Cache miss for key: {cache_key}, result cached.")
+                print(f"Cache miss for key: {cache_key}, result cached.")
                 return result
                 
         return wrapper
@@ -161,6 +166,8 @@ def clear_cache(
             async with _get_cache_lock(cache_key):
                 await FastAPICache.clear(key=cache_key)
                 result = await func(*args, **kwargs)
+                logging.info(f"Clearing cache for key: {cache_key}")
+                print(f"Clearing cache for key: {cache_key}")
                 return result
         
         return wrapper