import datetime as dt from datetime import date, timedelta import requests import pandas as pd import plotly.graph_objects as go from plotly.subplots import make_subplots import streamlit as st from streamlit_folium import st_folium import folium # ------------------------------ # Sayfa ayarları # ------------------------------ st.set_page_config( page_title="Open-Meteo • Haritadan Seç • Tahmin + Arşiv", page_icon="⛅", layout="wide" ) st.title("⛅ Open‑Meteo • Haritadan Konum Seç • Tahmin + Arşiv (CPU‑only)") st.caption( "Haritaya tıklayıp konumu seçin. Lejand öğelerine tıklayarak izleri aç/kapatabilir, " "yan menüden katmanları ve birimleri değiştirebilirsiniz. " "Çift tıklama = yalnızca seçili iz." ) # ------------------------------ # API uçları ve varsayılan değişkenler # ------------------------------ FORECAST_BASE = "https://api.open-meteo.com/v1/forecast" ARCHIVE_BASE = "https://archive-api.open-meteo.com/v1/archive" HOURLY_VARS = [ "temperature_2m", "relative_humidity_2m", "precipitation", "wind_speed_10m", "wind_direction_10m", "cloud_cover" ] # Günlükte güneş doğuş/batışını her koşulda tutuyoruz (gece-gündüz gölgeleme için gerekli) DAILY_VARS = [ "temperature_2m_max", "temperature_2m_min", "precipitation_sum", "wind_speed_10m_max", "sunrise", "sunset" ] # ------------------------------ # Yardımcılar # ------------------------------ def fetch_openmeteo(mode, lat, lon, *, start=None, end=None, forecast_days=7, temp_unit="celsius", wind_unit="kmh", precip_unit="mm"): """ Open-Meteo'dan veri çeker ve saatlik/günlük DataFrame döndürür. temp_unit: celsius|fahrenheit wind_unit: kmh|ms|mph|kn (Open-Meteo parametre adı: windspeed_unit) precip_unit: mm|inch """ params = { "latitude": lat, "longitude": lon, "timezone": "auto", "hourly": ",".join(HOURLY_VARS), "daily": ",".join(DAILY_VARS), "temperature_unit": temp_unit, "windspeed_unit": wind_unit, # <— DÜZELTİLDİ: windspeed_unit "precipitation_unit": precip_unit, } if mode == "Tahmin": params["forecast_days"] = int(forecast_days) url = FORECAST_BASE else: params["start_date"] = start params["end_date"] = end url = ARCHIVE_BASE r = requests.get(url, params=params, timeout=30) r.raise_for_status() data = r.json() tz = data.get("timezone", "GMT") # Saatlik DF hourly = data.get("hourly", {}) df_h = None if hourly.get("time"): df_h = pd.DataFrame(hourly) df_h["time"] = pd.to_datetime(df_h["time"]) df_h = df_h.set_index("time").sort_index() # Günlük DF daily = data.get("daily", {}) df_d = None if daily.get("time"): df_d = pd.DataFrame(daily) df_d["time"] = pd.to_datetime(df_d["time"]) # sunrise/sunset kolonlarını datetime'a çevir for col in ("sunrise", "sunset"): if col in df_d.columns: df_d[col] = pd.to_datetime(df_d[col], errors="coerce") df_d = df_d.set_index("time").sort_index() return tz, df_h, df_d, data def add_night_shading(fig, df_d, df_h): """Gün doğumu/batımı kullanarak gece bölümlerini arkaya açık renk gölge olarak ekler.""" if df_d is None or df_h is None: return fig if not {"sunrise", "sunset"}.issubset(df_d.columns): return fig if df_h.empty or df_d.empty: return fig h_start = df_h.index.min() h_end = df_h.index.max() shapes = [] for _, row in df_d.iterrows(): sr, ss = row.get("sunrise"), row.get("sunset") if pd.isna(sr) or pd.isna(ss): continue day_midnight = pd.Timestamp(sr.date()) next_midnight = day_midnight + pd.Timedelta(days=1) # Gece 1: 00:00 -> Gün doğumu left = max(day_midnight, h_start) right = min(sr, h_end) if left < right: shapes.append(dict( type="rect", xref="x", yref="paper", x0=left, x1=right, y0=0, y1=1, fillcolor="rgba(0,0,0,0.08)", line=dict(width=0), layer="below" )) # Gece 2: Gün batımı -> 24:00 left = max(ss, h_start) right = min(next_midnight, h_end) if left < right: shapes.append(dict( type="rect", xref="x", yref="paper", x0=left, x1=right, y0=0, y1=1, fillcolor="rgba(0,0,0,0.08)", line=dict(width=0), layer="below" )) if shapes: fig.update_layout(shapes=shapes) return fig def fig_hourly(df_h, tz_name, *, show_temp=True, show_precip=True, show_wind=True, temp_label="°C", precip_label="mm", wind_label="km/sa", smooth_window=1, df_d=None): """Saatlik grafik: sıcaklık, yağış, rüzgâr. İzleri checkbox ile seçilebilir; lejand tıklamasıyla aç/kapa.""" fig = make_subplots(specs=[[{"secondary_y": True}]]) dfp = df_h.copy() # Yumuşatma (yalnız çizgi serilere) if smooth_window and smooth_window > 1: if "temperature_2m" in dfp.columns: dfp["temperature_2m"] = dfp["temperature_2m"].rolling(smooth_window, min_periods=1).mean() if "wind_speed_10m" in dfp.columns: dfp["wind_speed_10m"] = dfp["wind_speed_10m"].rolling(smooth_window, min_periods=1).mean() if show_temp and "temperature_2m" in dfp: fig.add_trace(go.Scatter( x=dfp.index, y=dfp["temperature_2m"], mode="lines", name=f"Sıcaklık ({temp_label})" ), secondary_y=False) if show_precip and "precipitation" in dfp: fig.add_trace(go.Bar( x=dfp.index, y=dfp["precipitation"], name=f"Yağış ({precip_label})", opacity=0.35 ), secondary_y=True) if show_wind and "wind_speed_10m" in dfp: fig.add_trace(go.Scatter( x=dfp.index, y=dfp["wind_speed_10m"], mode="lines", name=f"Rüzgâr ({wind_label})" ), secondary_y=True) fig.update_layout( title=f"Saatlik Seri ({tz_name})", margin=dict(l=10, r=10, t=40, b=10), height=440, legend=dict(orientation="h", yanchor="bottom", y=1.02, xanchor="left", x=0), ) fig.update_xaxes(title_text="Zaman") fig.update_yaxes(title_text=f"Sıcaklık ({temp_label})", secondary_y=False) fig.update_yaxes(title_text=f"Yağış ({precip_label}) / Rüzgâr ({wind_label})", secondary_y=True) # Gece-gündüz gölgeleme fig = add_night_shading(fig, df_d, dfp) return fig def fig_daily(df_d, *, show_daily_precip=True, temp_label="°C", precip_label="mm"): """Günlük grafik: min‑max sıcaklık bandı + (opsiyonel) toplam yağış.""" fig = make_subplots(specs=[[{"secondary_y": True}]]) have_minmax = {"temperature_2m_min", "temperature_2m_max"}.issubset(df_d.columns) if have_minmax: fig.add_trace(go.Scatter( x=df_d.index, y=df_d["temperature_2m_min"], mode="lines", name=f"Günlük Min ({temp_label})" ), secondary_y=False) fig.add_trace(go.Scatter( x=df_d.index, y=df_d["temperature_2m_max"], mode="lines", name=f"Günlük Max ({temp_label})", fill="tonexty" ), secondary_y=False) if show_daily_precip and "precipitation_sum" in df_d: fig.add_trace(go.Bar( x=df_d.index, y=df_d["precipitation_sum"], name=f"Toplam Yağış ({precip_label})", opacity=0.35 ), secondary_y=True) fig.update_layout( title="Günlük Özet (Min‑Max Bandı & Yağış)", margin=dict(l=10, r=10, t=40, b=10), height=440, legend=dict(orientation="h", yanchor="bottom", y=1.02, xanchor="left", x=0), ) fig.update_xaxes(title_text="Tarih") fig.update_yaxes(title_text=f"Sıcaklık ({temp_label})", secondary_y=False) fig.update_yaxes(title_text=f"Yağış ({precip_label})", secondary_y=True) return fig def csv_bytes(df: pd.DataFrame) -> bytes: return df.to_csv(index=True).encode("utf-8") # ------------------------------ # Kenar çubuğu (ayarlar) # ------------------------------ with st.sidebar: st.header("⚙️ Ayarlar") mode = st.radio("Veri tipi", ["Tahmin", "Geçmiş (Arşiv)"], horizontal=True) if mode == "Tahmin": forecast_days = st.slider("Tahmin günü", min_value=1, max_value=16, value=7) else: today = date.today() default_start = today - timedelta(days=14) default_end = today - timedelta(days=5) # arşiv birkaç gün gecikmeli olur start_date = st.date_input("Başlangıç tarihi", value=default_start, max_value=today) end_date = st.date_input("Bitiş tarihi", value=default_end, max_value=today) if start_date > end_date: st.error("Başlangıç tarihi, bitiş tarihinden büyük olamaz.") st.markdown("---") st.subheader("📊 Grafik katmanları") show_temp = st.checkbox("Sıcaklık (saatlik)", value=True) show_precip = st.checkbox("Yağış (saatlik)", value=True) show_wind = st.checkbox("Rüzgâr hızı (saatlik)", value=True) show_daily_precip = st.checkbox("Günlük toplam yağış", value=True) st.markdown("---") st.subheader("🧰 Görselleştirme seçenekleri") smooth_window = st.slider("Saatlik çizgiler için yumuşatma (saat)", 1, 6, 1, help="1 = yumuşatma yok. Sadece çizgi serilere uygulanır (sıcaklık, rüzgâr).") st.markdown("---") st.subheader("📏 Birimler") colu1, colu2, colu3 = st.columns(3) with colu1: temp_choice = st.radio("Sıcaklık", ["°C", "°F"], horizontal=True, index=0) with colu2: wind_choice = st.radio("Rüzgâr", ["km/sa", "m/sn"], horizontal=True, index=0) with colu3: precip_choice = st.radio("Yağış", ["mm", "inç"], horizontal=True, index=0) # UI -> API birim eşlemesi temp_unit_api = "celsius" if temp_choice == "°C" else "fahrenheit" wind_unit_api = "kmh" if wind_choice == "km/sa" else "ms" precip_unit_api = "mm" if precip_choice == "mm" else "inch" temp_label = "°C" if temp_unit_api == "celsius" else "°F" wind_label = "km/sa" if wind_unit_api == "kmh" else "m/sn" precip_label = "mm" if precip_unit_api == "mm" else "in" # ------------------------------ # Harita (konum seçimi) + Favoriler # ------------------------------ st.subheader("🗺️ Konum seç") if "lat" not in st.session_state: st.session_state.lat = 41.0082 # İstanbul if "lon" not in st.session_state: st.session_state.lon = 28.9784 if "favorites" not in st.session_state: st.session_state.favorites = [] # {"name": str, "lat": float, "lon": float} col_map, col_info = st.columns([2.2, 1.0], vertical_alignment="top") with col_map: m = folium.Map(location=[st.session_state.lat, st.session_state.lon], zoom_start=6, control_scale=True) folium.Marker(location=[st.session_state.lat, st.session_state.lon], tooltip="Seçili konum").add_to(m) m.add_child(folium.LatLngPopup()) map_state = st_folium(m, use_container_width=True, height=460, returned_objects=["last_clicked"]) if map_state and map_state.get("last_clicked"): st.session_state.lat = round(float(map_state["last_clicked"]["lat"]), 5) st.session_state.lon = round(float(map_state["last_clicked"]["lng"]), 5) with col_info: st.write("**Seçili koordinatlar**") st.metric("Enlem (lat)", st.session_state.lat) st.metric("Boylam (lon)", st.session_state.lon) st.markdown("**⭐ Favoriler**") fav_name = st.text_input("Bu konumu isimlendir", placeholder="ör. İstanbul-Ofis") add_btn = st.button("Bu konumu favorilere ekle") if add_btn and fav_name.strip(): st.session_state.favorites.append({"name": fav_name.strip(), "lat": st.session_state.lat, "lon": st.session_state.lon}) st.success(f"“{fav_name}” eklendi.") if st.session_state.favorites: names = [f["name"] for f in st.session_state.favorites] sel = st.selectbox("Favori konumu yükle", names, index=None, placeholder="Seçin…") if sel: f = next(x for x in st.session_state.favorites if x["name"] == sel) if st.button("Seçili favoriye git"): st.session_state.lat = f["lat"] st.session_state.lon = f["lon"] # ------------------------------ # Veri çekme + görselleştirme # ------------------------------ st.subheader("📈 Grafikler ve İndirmeler") try: if mode == "Tahmin": tz, df_h, df_d, raw = fetch_openmeteo( mode="Tahmin", lat=st.session_state.lat, lon=st.session_state.lon, forecast_days=forecast_days, temp_unit=temp_unit_api, wind_unit=wind_unit_api, precip_unit=precip_unit_api ) else: tz, df_h, df_d, raw = fetch_openmeteo( mode="Geçmiş", lat=st.session_state.lat, lon=st.session_state.lon, start=start_date.isoformat(), end=end_date.isoformat(), temp_unit=temp_unit_api, wind_unit=wind_unit_api, precip_unit=precip_unit_api ) cfg = {"displaylogo": False, "displayModeBar": True} if df_h is not None and not df_h.empty: st.plotly_chart( fig_hourly( df_h, tz_name=tz, show_temp=show_temp, show_precip=show_precip, show_wind=show_wind, temp_label=temp_label, precip_label=precip_label, wind_label=wind_label, smooth_window=smooth_window, df_d=df_d ), use_container_width=True, config=cfg ) st.download_button("Saatlik veriyi CSV indir", data=csv_bytes(df_h), file_name="hourly.csv", mime="text/csv") if df_d is not None and not df_d.empty: st.plotly_chart( fig_daily( df_d, show_daily_precip=show_daily_precip, temp_label=temp_label, precip_label=precip_label ), use_container_width=True, config=cfg ) st.download_button("Günlük veriyi CSV indir", data=csv_bytes(df_d), file_name="daily.csv", mime="text/csv") if (df_h is None or df_h.empty) and (df_d is None or df_d.empty): st.info("Seçili aralık/konum için veri bulunamadı. Aralığı daraltmayı veya farklı konum seçmeyi deneyin.") except requests.HTTPError as e: st.error(f"Open‑Meteo isteği başarısız oldu: {e}") except Exception as e: st.error(f"Beklenmeyen bir hata oluştu: {e}")