modified: app.py
This commit is contained in:
58
app.py
58
app.py
@@ -21,41 +21,37 @@ def load_weather_data():
|
||||
# Extrahieren der relevanten Wetterdaten
|
||||
weather_data = []
|
||||
|
||||
print(json.dumps(entry, indent=2))
|
||||
# Annahme: Die Daten enthalten eine Liste von "messages"
|
||||
for message in data.get("messages", []):
|
||||
if isinstance(message, list):
|
||||
# Gehe die Wetterstationen durch, die in der Liste enthalten sind
|
||||
for station_data in message[1:]:
|
||||
station_info = {}
|
||||
if isinstance(station_data, list):
|
||||
for info in station_data:
|
||||
# Stelle sicher, dass info ein Dictionary ist
|
||||
if isinstance(info, dict):
|
||||
# Extrahiere die notwendigen Wetterinformationen
|
||||
if info.get("key") == "stationNumber":
|
||||
station_info["stationNumber"] = info.get("value")
|
||||
elif info.get("key") == "stationOrSiteName":
|
||||
station_info["stationName"] = info.get("value")
|
||||
elif info.get("key") == "airTemperature":
|
||||
station_info["temperature"] = round(info.get("value") - 273.15, 2) # Umrechnung von K in °C
|
||||
elif info.get("key") == "windSpeed":
|
||||
station_info["windSpeed"] = info.get("value")
|
||||
elif info.get("key") == "pressureReducedToMeanSeaLevel":
|
||||
station_info["pressure"] = info.get("value")
|
||||
|
||||
# Überprüfen, ob das "messages"-Feld im JSON vorhanden ist
|
||||
if "messages" in data:
|
||||
for message in data["messages"]:
|
||||
# "message" sollte eine Liste sein, die weitere Listen enthält
|
||||
if isinstance(message, list):
|
||||
for entry in message:
|
||||
# "entry" sollte entweder ein Dictionary oder eine Liste von Daten sein
|
||||
if isinstance(entry, list):
|
||||
station_info = {}
|
||||
for info in entry:
|
||||
# "info" sollte ein Dictionary sein
|
||||
if isinstance(info, dict):
|
||||
if info.get("key") == "stationNumber":
|
||||
station_info["stationNumber"] = info.get("value")
|
||||
elif info.get("key") == "stationOrSiteName":
|
||||
station_info["stationName"] = info.get("value")
|
||||
elif info.get("key") == "airTemperature":
|
||||
# Temperatur von Kelvin in Celsius umwandeln
|
||||
station_info["temperature"] = round(info.get("value") - 273.15, 2)
|
||||
elif info.get("key") == "windSpeed":
|
||||
station_info["windSpeed"] = info.get("value")
|
||||
elif info.get("key") == "pressureReducedToMeanSeaLevel":
|
||||
station_info["pressure"] = info.get("value")
|
||||
|
||||
# Füge nur Stationen mit Stationsnummer hinzu
|
||||
if "stationNumber" in station_info:
|
||||
weather_data.append(station_info)
|
||||
|
||||
# Sortiere nach stationNumber
|
||||
weather_data.sort(key=lambda x: x["stationNumber"])
|
||||
# Füge nur vollständige Stationsinformationen hinzu
|
||||
if station_info:
|
||||
weather_data.append(station_info)
|
||||
|
||||
# Sortiere die Daten nach stationNumber
|
||||
weather_data.sort(key=lambda x: x.get("stationNumber"))
|
||||
return weather_data
|
||||
|
||||
|
||||
# Flask Route für die Hauptseite
|
||||
@app.route('/')
|
||||
def index():
|
||||
|
||||
Reference in New Issue
Block a user