|
|
import aiohttp |
|
|
import asyncio |
|
|
import os |
|
|
import xarray as xr |
|
|
import requests |
|
|
from datetime import datetime |
|
|
from typing import Dict, Any |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class WeatherServer: |
|
|
"""Open-Meteo Weather API Server""" |
|
|
|
|
|
async def get_data(self, lat: float, lon: float) -> Dict[str, Any]: |
|
|
try: |
|
|
url = "https://api.open-meteo.com/v1/forecast" |
|
|
params = { |
|
|
"latitude": lat, |
|
|
"longitude": lon, |
|
|
"current": "temperature_2m,precipitation,wind_speed_10m,relative_humidity_2m", |
|
|
"daily": "temperature_2m_max,temperature_2m_min,precipitation_sum,rain_sum", |
|
|
"timezone": "Asia/Kolkata", |
|
|
"forecast_days": 7 |
|
|
} |
|
|
|
|
|
async with aiohttp.ClientSession() as session: |
|
|
async with session.get(url, params=params, timeout=aiohttp.ClientTimeout(total=10)) as response: |
|
|
if response.status == 200: |
|
|
data = await response.json() |
|
|
return { |
|
|
"status": "success", |
|
|
"data": { |
|
|
"current_temp_c": data["current"]["temperature_2m"], |
|
|
"current_precipitation_mm": data["current"]["precipitation"], |
|
|
"wind_speed_kmh": data["current"]["wind_speed_10m"], |
|
|
"humidity_percent": data["current"]["relative_humidity_2m"], |
|
|
"forecast_7day": { |
|
|
"max_temps": data["daily"]["temperature_2m_max"], |
|
|
"min_temps": data["daily"]["temperature_2m_min"], |
|
|
"precipitation_mm": data["daily"]["precipitation_sum"], |
|
|
"rain_mm": data["daily"]["rain_sum"] |
|
|
}, |
|
|
"data_source": "Open-Meteo API" |
|
|
} |
|
|
} |
|
|
else: |
|
|
return {"status": "error", "error": f"HTTP {response.status}"} |
|
|
except Exception as e: |
|
|
return {"status": "error", "error": str(e)} |
