Refine

2025-04-15 21:38:16 +08:00
parent 0384b40baa
commit e9b01a5b50
1 changed files with 3 additions and 2 deletions
--- a/main.py
+++ b/main.py
@@ -2330,9 +2330,10 @@ async def fastapi_query_all_records_by_date(querydate: str) -> dict[str, list]:

        data = redis_client.get(cache_key)
        if data:
-            logger.info(f"return from cache redis")
            # 使用自定义的反序列化函数
-            return msgpack.unpackb(data, object_hook=decode_datetime)
+            results = msgpack.unpackb(data, object_hook=decode_datetime)
+            logger.info(f"return from cache redis")
+            return results

    logger.info(f"query from influxdb")