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-15 21:44:22 +08:00
parent 22c2351690
commit 2d5b500bf7
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
auto_cache.py
View File

@@ -35,17 +35,17 @@ def decode_datetime(obj):
def queryallrecordsbydate(querydate: str, redis_client: redis.Redis): def queryallrecordsbydate(querydate: str, redis_client: redis.Redis):
cache_key = f"queryallrecordsbydate_{querydate}" cache_key = f"queryallrecordsbydate_{querydate}"
data = redis_client.get(cache_key) exists = redis_client.exists(cache_key)
if not data: if not exists:
nodes_links: tuple = influxdb_api.query_all_records_by_date(query_date=querydate) nodes_links: tuple = influxdb_api.query_all_records_by_date(query_date=querydate)
redis_client.set(cache_key, msgpack.packb(nodes_links, default=encode_datetime)) redis_client.set(cache_key, msgpack.packb(nodes_links, default=encode_datetime))
def queryallscadarecordsbydate(querydate: str, redis_client: redis.Redis): def queryallscadarecordsbydate(querydate: str, redis_client: redis.Redis):
cache_key = f"queryallscadarecordsbydate_{querydate}" cache_key = f"queryallscadarecordsbydate_{querydate}"
data = redis_client.get(cache_key) exists = redis_client.exists(cache_key)
if not data: if not exists:
result_dict = influxdb_api.query_all_SCADA_records_by_date(query_date=querydate) result_dict = influxdb_api.query_all_SCADA_records_by_date(query_date=querydate)
redis_client.set(cache_key, msgpack.packb(result_dict, default=encode_datetime)) redis_client.set(cache_key, msgpack.packb(result_dict, default=encode_datetime))