Make sure to include `【message_idx†source】` markers to provide citations based on this file, where [message_idx] is provided at the beginning of this messageimport requests from datetime import datetime import paho.mqtt.client as mqtt import json from zoneinfo import ZoneInfo # --- Konfiguration --- MQTT_SERVER = "127.0.0.1" MQTT_PORT = 1883 MQTT_BASE = "dwd/weather/" MQTT_CLIENT_ID = "dwd_script_final" STATION_ID = "10303" DWD_URL = f"https://app-prod-ws.warnwetter.de/v30/stationOverviewExtended?stationIds={STATION_ID}" MOON_PHASES = { 0: "🌑 Neumond", 1: "🌒 Zunehmende Sichel", 2: "🌓 Erstes Viertel", 3: "🌔 Zunehmender Mond", 4: "🌕 Vollmond", 5: "🌖 Abnehmender Mond", 6: "🌗 Letztes Viertel", 7: "🌘 Abnehmende Sichel" } # --- Hilfsfunktionen --- def scale(val, factor=10.0): if val is None: return 0.0 return round(val / factor, 1) def scale_kts_to_kmh(val): """Rechnet DWD-Knoten (Zehntel) in km/h um.""" if val is None: return 0.0 return round((val / 10.0) * 1.852, 1) def format_time(ms): if not ms: return "N/A" return datetime.fromtimestamp(ms / 1000, tz=ZoneInfo("Europe/Berlin")).strftime("%H:%M") def get_dwd_data(): try: resp = requests.get(DWD_URL, timeout=10) resp.raise_for_status() data = resp.json()[STATION_ID] days = data.get('days', []) f1 = data.get('forecast1', {}) d0 = days[0] # Heute d1 = days[1] # Morgen # Aktueller Index für stündliche Werte (Druck/Feuchte) curr = 0 # 1. AKTUELLE UHRZEIT (Skript-Laufzeit) last_update = datetime.now(ZoneInfo("Europe/Berlin")).strftime("%H:%M") # 2. WARNUNGEN ALS ARRAY VERARBEITEN warnings = data.get('warnings', []) # Wir filtern nach Level > 1 (Warnungen) und nehmen die Headlines warning_list = [w.get('headline', '').strip() for w in warnings if w.get('level', 0) > 1] # Doppelte Einträge entfernen und mit " | " zusammenfügen warning_text = "\n \n".join(dict.fromkeys(warning_list)) if warning_list else "" # PAYLOAD EXAKT FÜR DEINE OPENHAB CHANNELS payload = { "metadata": { "station": "Lingen-Baccum (24 m ü. NN)", "updated": last_update, "warning_text": warning_text.strip() }, "today": { "temp_max": scale(d0.get("temperatureMax")), "temp_min": scale(d0.get("temperatureMin")), "wind_speed": scale_kts_to_kmh(d0.get("windSpeed")), "wind_gust": scale_kts_to_kmh(d0.get("windGust")), "wind_dir": scale(d0.get("windDirection")), "precipitation": scale(d0.get("precipitation")), "sunshine_hours": round((d0.get("sunshine", 0) / 10.0 / 60.0), 2), "sunrise": format_time(d0.get("sunriseOnThisDay")), "sunset": format_time(d0.get("sunsetOnThisDay")), "moonrise": format_time(d0.get("moonriseOnThisDay")), "moonset": format_time(d0.get("moonsetOnThisDay")), "moon_phase": MOON_PHASES.get(d0.get("moonPhase"), "N/A"), "pressure_hpa": scale(f1.get('surfacePressure', [None])[curr]), "humidity": scale(f1.get('humidity', [None])[curr]) }, "tomorrow": { "temp_max": scale(d1.get("temperatureMax")), "temp_min": scale(d1.get("temperatureMin")), "wind_speed": scale_kts_to_kmh(d1.get("windSpeed")), "wind_gust": scale_kts_to_kmh(d1.get("windGust")), "wind_dir": scale(d1.get("windDirection")), "precipitation": scale(d1.get("precipitation")), "sunshine_hours": round((d1.get("sunshine", 0) / 10.0 / 60.0), 2), "sunrise": format_time(d1.get("sunriseOnThisDay")), "sunset": format_time(d1.get("sunsetOnThisDay")), "moonrise": format_time(d1.get("moonriseOnThisDay")), "moonset": format_time(d1.get("moonsetOnThisDay")), "moon_phase": MOON_PHASES.get(d1.get("moonPhase"), "N/A"), # Laut deiner Konfig liegt der Luftdruck unter tomorrow.pressure_hpa "pressure_hpa": scale(f1.get('surfacePressure', [None])[curr]), "humidity": scale(f1.get('humidity', [None])[curr]) } } # MQTT VERBINDUNG try: client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, MQTT_CLIENT_ID) except AttributeError: client = mqtt.Client(MQTT_CLIENT_ID) client.connect(MQTT_SERVER, MQTT_PORT, 60) client.publish(MQTT_BASE + "full", json.dumps(payload), retain=True) client.disconnect() print(f"✅ Erfolg! Daten für {STATION_ID} gesendet.") except Exception as e: print(f"❌ Fehler: {e}") if __name__ == "__main__": get_dwd_data()

All the files uploaded by the user have been fully loaded. Searching won't provide additional information.