modified: app.py
This commit is contained in:
31
app.py
31
app.py
@@ -18,40 +18,13 @@ def download_and_extract(url):
|
||||
else:
|
||||
return None
|
||||
|
||||
# Funktion zum Extrahieren bestimmter Wetterdaten
|
||||
def extract_relevant_data(weather_data):
|
||||
relevant_data = []
|
||||
|
||||
# 'messages' sind die Blöcke, die wir durchlaufen
|
||||
messages = weather_data.get('messages', [])
|
||||
|
||||
# Durchlaufe alle 'messages' und extrahiere relevante Daten
|
||||
for message in messages[0]: # Annahme: die Daten befinden sich im ersten Element
|
||||
if isinstance(message, list):
|
||||
subset_data = {}
|
||||
for item in message:
|
||||
if isinstance(item, dict):
|
||||
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 # In Celsius umrechnen
|
||||
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
|
||||
# Flask-Route, die die Wetterdaten bereitstellt
|
||||
@app.route('/weather')
|
||||
def weather():
|
||||
data = download_and_extract(url)
|
||||
if data:
|
||||
weather_data = json.loads(data)
|
||||
filtered_data = extract_relevant_data(weather_data)
|
||||
return jsonify(filtered_data) # Nur die relevanten Daten zurückgeben
|
||||
return jsonify(weather_data)
|
||||
else:
|
||||
return jsonify({"error": "Fehler beim Abrufen der Wetterdaten"}), 500
|
||||
|
||||
|
||||
Reference in New Issue
Block a user