OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refine

Browse Source
This commit is contained in:
DingZQ
2025-03-28 22:48:50 +08:00
parent 27fd74dfbf
commit b8c08ac89c
1 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
main.py
View File

@@ -2337,23 +2337,6 @@ async def fastapi_query_all_scheme_all_records(schemetype: str, schemename: str,
return results 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 # DingZQ, 2025-03-21
# 缓存是用的queryallschemeallrecords的缓存 # 缓存是用的queryallschemeallrecords的缓存
@app.get("/queryschemeallrecordsproperty/") @app.get("/queryschemeallrecordsproperty/")