diff --git a/main.py b/main.py index 915a382..468c559 100644 --- a/main.py +++ b/main.py @@ -2337,23 +2337,6 @@ async def fastapi_query_all_scheme_all_records(schemetype: str, schemename: str, return results -@app.get("/queryallschemeallrecords/") -async def fastapi_query_all_scheme_all_records(schemetype: str, schemename: str, querydate: str) -> tuple: - # 缓存查询结果提高性能 - global redis_client - cache_key = f"queryallschemeallrecords_{schemetype}_{schemename}_{querydate}" - data = redis_client.get(cache_key) - if data: - # 使用自定义的反序列化函数 - loaded_dict = msgpack.unpackb(data, object_hook=object_hook) - return loaded_dict - - results = influxdb_api.query_scheme_all_record(scheme_Type=schemetype, scheme_Name=schemename, query_date=querydate) - packed = msgpack.packb(results, default=default_encoder) - redis_client.set(cache_key, packed) - - return results - # DingZQ, 2025-03-21 # 缓存是用的queryallschemeallrecords的缓存 @app.get("/queryschemeallrecordsproperty/")