modified: app.py

app.py

@@ -21,19 +21,30 @@ def download_and_extract(url):
 # 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)
+    
+    # Hier überprüfen wir die Struktur der Daten
+    messages = weather_data.get('messages', [])
+    
+    # Debug-Ausgabe der Nachrichten, um die Struktur zu überprüfen
+    print("Erster Nachrichtenblock:", messages[0])
+    
+    # Durchlaufe alle Nachrichtenblöcke
+    for message in messages[0]:  # Nimm an, dass 'messages' eine Liste ist
+        if isinstance(message, list):
+            subset_data = {}
+            for item in message:
+                if isinstance(item, dict):  # Nur mit Diktaten arbeiten
+                    if item.get('key') == 'stationOrSiteName':
+                        subset_data['station'] = item.get('value')
+                    elif item.get('key') == 'airTemperature':
+                        subset_data['temperature'] = item.get('value', 0) - 273.15  # Umrechnung in Celsius
+                    elif item.get('key') == 'pressureReducedToMeanSeaLevel':
+                        subset_data['pressure'] = item.get('value')
+                    elif item.get('key') == 'windSpeed':
+                        subset_data['wind_speed'] = item.get('value')
+            if subset_data:
+                relevant_data.append(subset_data)
+    
     return relevant_data
 
 # API-Route für gefilterte Wetterdaten
@@ -42,6 +53,10 @@ def weather():
     data = download_and_extract(url)
     if data:
         weather_data = json.loads(data)
+        
+        # Struktur der Daten prüfen
+        print("Datenstruktur:", weather_data)
+        
         filtered_data = extract_relevant_data(weather_data)
         return jsonify(filtered_data)
     else: