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

Update auto_cache

Browse Source
This commit is contained in:
DingZQ
2025-03-22 08:29:07 +08:00
parent 9c24dab4a3
commit 790db21a8e
1 changed files with 50 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
auto_cache.py
View File

@@ -5,16 +5,51 @@ import shutil
import redis
import urllib.request
def query_all_records_by_date_with_type_link(date: str):
def query_all_records_by_date_with_type(date: str):
try:
response = urllib.request.urlopen(f'http://localhost/queryallrecordsbydatewithtype/?querydate={date}&querytype=node')
html = response.read().decode('utf-8')
print(html)
response = urllib.request.urlopen(f'http://localhost/queryallrecordsbydatewithtype/?querydate={date}&querytype=link')
html = response.read().decode('utf-8')
print(html)
except urllib.error.URLError as e:
print("Error")
def auto_cache_data():
def queryallrecordsbydateproperty(date: str):
try:
response = urllib.request.urlopen(f'http://localhost/queryallrecordsbydateproperty/?querydate={date}&querytype=node&property=head')
html = response.read().decode('utf-8')
print(html)
response = urllib.request.urlopen(f'http://localhost/queryallrecordsbydateproperty/?querydate={date}&querytype=link&property=flow')
html = response.read().decode('utf-8')
print(html)
except urllib.error.URLError as e:
print("Error")
def queryallscadarecordsbydate(date: str):
try:
response = urllib.request.urlopen(f'http://localhost/queryallscadarecordsbydate/?querydate={date}')
html = response.read().decode('utf-8')
print(html)
except urllib.error.URLError as e:
print("Error")
def queryallschemeallrecords(date: str):
try:
response = urllib.request.urlopen(f'http://localhost/queryallschemeallrecords/?schemetype=burst_Analysis&schemename=testSchema&querydate={date}')
html = response.read().decode('utf-8')
print(html)
except urllib.error.URLError as e:
print("Error")
def auto_cache_data():
"""
redis_client = redis.Redis(host='localhost', port=6379, db=0)
items = ['queryallrecordsbydatewithtype_[DATE]_link']
@@ -29,10 +64,23 @@ def auto_cache_data():
if not redis_client.exists(key):
query_all_records_by_date_with_type_link(str_prev_day)
"""
today = datetime.date.today()
prev_day = today - datetime.timedelta(days=1)
str_prev_day = prev_day.strftime('%Y-%m-%d')
print(str_prev_day)
query_all_records_by_date_with_type(str_prev_day)
queryallrecordsbydateproperty(str_prev_day)
queryallscadarecordsbydate(str_prev_day)
queryallschemeallrecords(str_prev_day)
if __name__ == "__main__":
auto_cache_data()
schedule.every().day.at("03:00").do(auto_cache_data)
while True:
schedule.run_pending()
time.sleep(1)