diff --git a/main.py b/main.py index 5607704..580d2d0 100644 --- a/main.py +++ b/main.py @@ -2697,10 +2697,10 @@ async def fastapi_burst_analysis(data: BurstAnalysis) -> str: 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) 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) redis_client.set(cache_key, packed)