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-04-04 12:49:38 +08:00
parent d7f8d1e90f
commit 1c72b08095
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
main.py
View File

@@ -2697,10 +2697,10 @@ async def fastapi_burst_analysis(data: BurstAnalysis) -> str:
print(f"schemename: {schemename}, querydate: {querydate}") print(f"schemename: {schemename}, querydate: {querydate}")
cache_key = f"queryallschemeallrecords_burst_{schemename}_{querydate}" cache_key = f"queryallschemeallrecords_burst_Analysis_{schemename}_{querydate}"
data = redis_client.get(cache_key) data = redis_client.get(cache_key)
if not data: if not data:
results = influxdb_api.query_scheme_all_record("burst", scheme_Name=schemename, query_date=querydate) results = influxdb_api.query_scheme_all_record("burst_Analysis", scheme_Name=schemename, query_date=querydate)
packed = msgpack.packb(results, default=encode_datetime) packed = msgpack.packb(results, default=encode_datetime)
redis_client.set(cache_key, packed) redis_client.set(cache_key, packed)