modified: app.py

app.py

@@ -16,26 +16,33 @@ def fetch_weather_data():
         decompressed_data = bz2.decompress(response.content)
         weather_data = json.loads(decompressed_data)
         
-        # Liste zur Speicherung der StationNumbers
-        station_data = []
+        # Liste, um die Stationsnummern zu speichern
+        station_numbers = []
+
+        # Durchlaufe alle Nachrichten und versuche, die Stationsnummern zu extrahieren
         for message in weather_data.get('messages', []):
             for subset in message[1]:
                 station_info = {}
                 for data_point in subset:
                     if isinstance(data_point, list):
-                        # Nur die stationNumber extrahieren
+                        # Suchen nach der Stationsnummer
                         for entry in data_point:
-                            if entry['key'] == 'stationNumber':
-                                station_info['stationNumber'] = entry['value']
+                            if entry.get('key') == 'stationNumber':
+                                station_info['stationNumber'] = entry.get('value')
+                                
+                # Füge nur die Objekte mit einer validen Stationsnummer hinzu
                 if 'stationNumber' in station_info:
-                    station_data.append(station_info)  # Nur hinzufügen, wenn stationNumber existiert
+                    station_numbers.append(station_info)
+
+        # Sortiere die Stationen nach der `stationNumber`
+        sorted_stations = sorted(station_numbers, key=lambda x: x['stationNumber'])
         
-        # Sortiere die Daten nach der StationNumber
-        station_data = sorted(station_data, key=lambda x: x.get('stationNumber', 0))
-        return station_data
+        return sorted_stations
+    
     return []
 
 
+
 # Route für die Hauptseite
 @app.route('/')
 def index():