Spaces:
Running
Running
File size: 1,960 Bytes
0bbef95 1c317c4 0bbef95 1c317c4 0bbef95 6fe10c5 0bbef95 1c317c4 0bbef95 1c317c4 0bbef95 26b2b64 0bbef95 26b2b64 0bbef95 1c317c4 |
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 58 59 60 61 62 63 64 65 66 |
import requests
import pandas as pd
from datetime import datetime
import csv,os
def get_data():
api_key = os.environ.get('AIR_QUALITY_API')
latitude = 19.0336118
longitude = 73.0181395749251
aqicn_base_url = f'http://api.openweathermap.org/data/2.5/air_pollution?lat={latitude}&lon={longitude}'
aqicn_url = f'{aqicn_base_url}&appid={api_key}'
response = requests.get(aqicn_url)
if response.status_code == 200:
data = response.json()
print("Air Quality Data fetched successfully:", data)
return data
else:
print("Failed to fetch Air Quality Data. Status code:", response.status_code)
return None
def update_csv(data, csv_filename= '/home/runner/work/air-quality/air-quality/air_quality_data.csv'):
header = ['Timestamp', 'PM2.5', 'PM10','O3','NO2','SO2', 'CO']
params = [[d['components']['pm2_5'],d['components']['pm10'],d['components']['o3'],d['components']['no2'],d['components']['so2'],d['components']['co']] for d in data['list']]
row = [
datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
params[0][0],
params[0][1],
params[0][2],
params[0][3],
params[0][4],
params[0][5],
]
try:
os.makedirs(os.path.dirname(csv_filename), exist_ok=True)
file_exists = os.path.isfile(csv_filename) and os.path.getsize(csv_filename) >0
with open(csv_filename, 'a', newline='') as csvfile:
csv_writer = csv.writer(csvfile)
if not file_exists:
csv_writer.writerow(header)
csv_writer.writerow(row)
print("Data successfully added to CSV.")
except Exception as e:
print(f"Error writing to CSV: {e}")
if __name__ == "__main__":
print("Current Working Directory:", os.getcwd()) # Print the current working directory
air_quality_data = get_data()
if air_quality_data:
update_csv(air_quality_data)
|