-
Notifications
You must be signed in to change notification settings - Fork 0
/
import-uwa-csv.txt
57 lines (48 loc) · 1.51 KB
/
import-uwa-csv.txt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
import csv
import requests
import datetime
import schedule
import time
# Define the URL and parameters for fetching the data
url = "http://www-k12.atmos.washington.edu/k12/grayskies/plot_nw_wx.cgi"
params = {
"Measurement": ["Temperature", "Relhum", "Speed", "Direction", "Pressure", "Solar", "SumRain", "Rain"],
"station": "UWA",
"interval": "0",
"timezone": "0",
"rightlab": "y",
"connect": "dataonly",
"groupby": "overlay",
"begmonth": "6",
"begday": "1",
"begyear": "2023",
"beghour": "0",
"endmonth": str(datetime.datetime.now().month),
"endday": str(datetime.datetime.now().day),
"endyear": str(datetime.datetime.now().year),
"endhour": "23"
}
csv_file = "2023-uwa.csv"
def fetch_data():
response = requests.get(url, params=params)
if response.status_code == 200:
data = response.text
# Write the data to a CSV file
with open(csv_file, "w", newline="") as file:
writer = csv.writer(file)
for row in data.splitlines():
split_data = row.split(",")
writer.writerow(split_data)
print(f"Data fetched and saved successfully. File saved at: {csv_file}")
def job():
print("Checking for new data...")
fetch_data()
print("Data fetch and save completed.")
# Run the job immediately when you press "run"
job()
# Schedule the job to run every hour
schedule.every().hour.do(job)
# Run the scheduler in an infinite loop
while True:
schedule.run_pending()
time.sleep(1)