gilles
3b1601a07b
- Remplace le service meteo.py minimal par une version enrichie : past_days=7 + forecast=8, champs humidite_moy, sol_0cm, etp_mm - Corrige les noms de champs API (weather_code, wind_speed_10m_max) et passe les paramètres daily en liste de tuples pour compatibilité - Ajoute fetch_and_store_forecast() pour le scheduler (Task 6) - Conserve fetch_forecast() pour compatibilité ascendante (GET /api/meteo) - Crée backend/tests/test_meteo.py (test_health passe, 3 autres échouent en attente des endpoints Task 7) Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
94 lines
3.5 KiB
Python
94 lines
3.5 KiB
Python
"""Service Open-Meteo — enrichi avec sol, ETP, humidité, données passées."""
|
|
import logging
|
|
from datetime import datetime, date, timezone
|
|
from typing import Any
|
|
|
|
import httpx
|
|
|
|
from app.config import METEO_LAT, METEO_LON
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
WMO_LABELS = {
|
|
0: "Ensoleillé", 1: "Principalement ensoleillé", 2: "Partiellement nuageux",
|
|
3: "Couvert", 45: "Brouillard", 48: "Brouillard givrant",
|
|
51: "Bruine légère", 53: "Bruine modérée", 55: "Bruine dense",
|
|
61: "Pluie légère", 63: "Pluie modérée", 65: "Pluie forte",
|
|
71: "Neige légère", 73: "Neige modérée", 75: "Neige forte",
|
|
80: "Averses légères", 81: "Averses modérées", 82: "Averses violentes",
|
|
85: "Averses de neige", 95: "Orage", 96: "Orage avec grêle", 99: "Orage violent",
|
|
}
|
|
|
|
# Champs daily disponibles (noms v1 actuels de l'API Open-Meteo)
|
|
# Nota : soil_temperature_0cm est hourly uniquement ; windspeed_10m_max et
|
|
# weathercode ont été renommés en wind_speed_10m_max et weather_code.
|
|
_DAILY_FIELDS = [
|
|
"temperature_2m_max",
|
|
"temperature_2m_min",
|
|
"precipitation_sum",
|
|
"wind_speed_10m_max",
|
|
"weather_code",
|
|
"relative_humidity_2m_max",
|
|
"et0_fao_evapotranspiration",
|
|
]
|
|
|
|
|
|
def fetch_and_store_forecast(lat: float = METEO_LAT, lon: float = METEO_LON) -> list[dict]:
|
|
"""Appelle Open-Meteo et retourne la liste des jours (past_days=7 + forecast=8).
|
|
|
|
Retourne la liste des jours pour être stockée en base par le scheduler.
|
|
"""
|
|
url = "https://api.open-meteo.com/v1/forecast"
|
|
# Passer chaque champ séparément (liste de tuples) pour éviter l'encodage
|
|
# d'une chaîne CSV qui est rejetée par certaines versions de l'API.
|
|
params: list[tuple[str, Any]] = [
|
|
("latitude", lat),
|
|
("longitude", lon),
|
|
("past_days", 7),
|
|
("forecast_days", 8),
|
|
("timezone", "Europe/Paris"),
|
|
]
|
|
for field in _DAILY_FIELDS:
|
|
params.append(("daily", field))
|
|
|
|
try:
|
|
r = httpx.get(url, params=params, timeout=15)
|
|
r.raise_for_status()
|
|
raw = r.json()
|
|
except Exception as e:
|
|
logger.error(f"Open-Meteo fetch error: {e}")
|
|
return []
|
|
|
|
daily = raw.get("daily", {})
|
|
dates = daily.get("time", [])
|
|
now_iso = datetime.now(timezone.utc).isoformat()
|
|
rows = []
|
|
|
|
for i, d in enumerate(dates):
|
|
code = int(daily.get("weather_code", [0] * len(dates))[i] or 0)
|
|
row = {
|
|
"date": d,
|
|
"t_min": daily.get("temperature_2m_min", [None] * len(dates))[i],
|
|
"t_max": daily.get("temperature_2m_max", [None] * len(dates))[i],
|
|
"pluie_mm": daily.get("precipitation_sum", [0] * len(dates))[i] or 0.0,
|
|
"vent_kmh": daily.get("wind_speed_10m_max", [0] * len(dates))[i] or 0.0,
|
|
"wmo": code,
|
|
"label": WMO_LABELS.get(code, f"Code {code}"),
|
|
"humidite_moy": daily.get("relative_humidity_2m_max", [None] * len(dates))[i],
|
|
"sol_0cm": None, # soil_temperature_0cm est hourly uniquement
|
|
"etp_mm": daily.get("et0_fao_evapotranspiration", [None] * len(dates))[i],
|
|
"fetched_at": now_iso,
|
|
}
|
|
rows.append(row)
|
|
|
|
return rows
|
|
|
|
|
|
def fetch_forecast(lat: float = METEO_LAT, lon: float = METEO_LON, days: int = 14) -> dict[str, Any]:
|
|
"""Compatibilité ascendante avec l'ancien endpoint GET /api/meteo."""
|
|
rows = fetch_and_store_forecast(lat, lon)
|
|
# Filtrer seulement les jours futurs (à partir d'aujourd'hui)
|
|
today = date.today().isoformat()
|
|
future = [r for r in rows if r["date"] >= today][:days]
|
|
return {"days": future}
|