modified: app.py
This commit is contained in:
58
app.py
58
app.py
@@ -17,34 +17,50 @@ def load_weather_data():
|
|||||||
|
|
||||||
# Parsen der JSON-Daten
|
# Parsen der JSON-Daten
|
||||||
data = json.loads(decompressed_data.decode('utf-8'))
|
data = json.loads(decompressed_data.decode('utf-8'))
|
||||||
|
|
||||||
|
# Debug: Ausgabe der ersten Nachricht für Analysezwecke
|
||||||
|
print(json.dumps(data["messages"][:1], indent=4))
|
||||||
|
|
||||||
# Extrahieren der relevanten Wetterdaten
|
# Extrahieren der relevanten Wetterdaten
|
||||||
weather_data = []
|
weather_data = []
|
||||||
|
|
||||||
# Beispielhafte Iteration über die JSON-Daten (anpassen, wenn die Struktur bekannt ist)
|
# Verarbeite die Nachrichten
|
||||||
for message in data["messages"]:
|
for message in data["messages"]:
|
||||||
# Gehe tiefer in die Struktur, je nachdem wie die Daten aufgebaut sind
|
# Debug: Nachricht anzeigen, um zu überprüfen, ob sie korrekt verarbeitet wird
|
||||||
for station_data in message[1:]:
|
print(f"Processing message: {message}")
|
||||||
station_info = {}
|
|
||||||
if isinstance(station_data, list):
|
# Prüfen, ob message eine Liste ist
|
||||||
for info in station_data:
|
if isinstance(message, list):
|
||||||
if isinstance(info, dict) and "key" in info:
|
for station_data in message[1:]: # Die eigentlichen Wetterdaten scheinen ab dem zweiten Element zu sein
|
||||||
if info["key"] == "stationNumber":
|
station_info = {}
|
||||||
station_info["stationNumber"] = info["value"]
|
if isinstance(station_data, list):
|
||||||
elif info["key"] == "stationOrSiteName":
|
for info in station_data:
|
||||||
station_info["stationName"] = info["value"]
|
# Prüfe, ob info ein Dictionary ist
|
||||||
elif info["key"] == "airTemperature":
|
if isinstance(info, dict):
|
||||||
station_info["temperature"] = round(info["value"] - 273.15, 2) # Umwandlung von K in °C
|
# Debug: Anzeigen, was info ist
|
||||||
elif info["key"] == "windSpeed":
|
print(f"Processing station info: {info}")
|
||||||
station_info["windSpeed"] = info["value"]
|
if "key" in info:
|
||||||
elif info["key"] == "pressureReducedToMeanSeaLevel":
|
if info["key"] == "stationNumber":
|
||||||
station_info["pressure"] = info["value"]
|
station_info["stationNumber"] = info["value"]
|
||||||
|
elif info["key"] == "stationOrSiteName":
|
||||||
if "stationNumber" in station_info:
|
station_info["stationName"] = info["value"]
|
||||||
weather_data.append(station_info)
|
elif info["key"] == "airTemperature":
|
||||||
|
station_info["temperature"] = round(info["value"] - 273.15, 2) # Umwandlung von K in °C
|
||||||
|
elif info["key"] == "windSpeed":
|
||||||
|
station_info["windSpeed"] = info["value"]
|
||||||
|
elif info["key"] == "pressureReducedToMeanSeaLevel":
|
||||||
|
station_info["pressure"] = info["value"]
|
||||||
|
|
||||||
|
# Nur vollständige Datensätze hinzufügen
|
||||||
|
if "stationNumber" in station_info:
|
||||||
|
weather_data.append(station_info)
|
||||||
|
|
||||||
|
# Sortiere nach stationNumber
|
||||||
|
weather_data.sort(key=lambda x: x["stationNumber"])
|
||||||
|
|
||||||
return weather_data
|
return weather_data
|
||||||
|
|
||||||
|
|
||||||
# Flask Route für die Hauptseite
|
# Flask Route für die Hauptseite
|
||||||
@app.route('/')
|
@app.route('/')
|
||||||
def index():
|
def index():
|
||||||
|
|||||||
Reference in New Issue
Block a user