优化数据保存功能,添加时间戳并移除定时任务;新增获取general信息的功能
This commit is contained in:
19
general.py
19
general.py
@@ -1,7 +1,5 @@
|
||||
import csv
|
||||
from datetime import datetime
|
||||
import time
|
||||
import schedule
|
||||
import requests
|
||||
|
||||
PHASE_URL = "https://backend.dexrp.io/general/phase"
|
||||
@@ -23,8 +21,10 @@ def save_to_csv(filename, data):
|
||||
with open(filename, "a", newline="") as f:
|
||||
writer = csv.writer(f)
|
||||
if f.tell() == 0: # Write header if file is empty
|
||||
writer.writerow(data.keys())
|
||||
writer.writerow(data.values())
|
||||
writer.writerow(["datetime"] + list(data.keys()))
|
||||
writer.writerow(
|
||||
[datetime.now().strftime("%Y-%m-%d %H:%M:%S")] + list(data.values())
|
||||
)
|
||||
except Exception as e:
|
||||
print(f"Error saving to {filename}: {e}")
|
||||
|
||||
@@ -52,14 +52,5 @@ def job():
|
||||
save_to_csv("general.csv", filtered_general)
|
||||
|
||||
|
||||
def main():
|
||||
schedule.every(10).minutes.do(job)
|
||||
job() # Run immediately first time
|
||||
|
||||
while True:
|
||||
schedule.run_pending()
|
||||
time.sleep(1)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
job()
|
||||
|
Reference in New Issue
Block a user