modified: app.py

app.py

@@ -18,30 +18,31 @@ def download_and_extract(url):
     else:
         return None
 
-# Flask-Route, die nur relevante Wetterdaten bereitstellt
+# Funktion zum Extrahieren bestimmter Wetterdaten
+def extract_relevant_data(weather_data):
+    relevant_data = []
+    for message in weather_data['messages'][0]:
+        subset_data = {}
+        for item in message:
+            if item['key'] == 'stationOrSiteName':
+                subset_data['station'] = item['value']
+            elif item['key'] == 'airTemperature':
+                subset_data['temperature'] = item['value'] - 273.15  # Umrechnung in Celsius
+            elif item['key'] == 'pressureReducedToMeanSeaLevel':
+                subset_data['pressure'] = item['value']
+            elif item['key'] == 'windSpeed':
+                subset_data['wind_speed'] = item['value']
+        if subset_data:
+            relevant_data.append(subset_data)
+    return relevant_data
+
+# API-Route für gefilterte Wetterdaten
 @app.route('/weather')
 def weather():
     data = download_and_extract(url)
     if data:
         weather_data = json.loads(data)
-        filtered_data = []
-
-        # Wichtige Wetterinformationen extrahieren
-        for message in weather_data['messages']:
-            for subset in message:
-                station_name = next((item['value'] for item in subset if item['key'] == 'stationOrSiteName'), None)
-                air_temperature = next((item['value'] for item in subset if item['key'] == 'airTemperature'), None)
-                pressure = next((item['value'] for item in subset if item['key'] == 'pressureReducedToMeanSeaLevel'), None)
-                wind_speed = next((item['value'] for item in subset if item['key'] == 'windSpeed'), None)
-
-                if station_name and air_temperature and pressure and wind_speed:
-                    filtered_data.append({
-                        "station": station_name,
-                        "temperature": air_temperature - 273.15,  # Umrechnung von Kelvin in Celsius
-                        "pressure": pressure / 100,  # Pa in hPa
-                        "wind_speed": wind_speed
-                    })
-
+        filtered_data = extract_relevant_data(weather_data)
         return jsonify(filtered_data)
     else:
         return jsonify({"error": "Fehler beim Abrufen der Wetterdaten"}), 500