modified: app.py
This commit is contained in:
50
app.py
50
app.py
@@ -16,42 +16,34 @@ def fetch_weather_data():
|
||||
decompressed_data = bz2.decompress(response.content)
|
||||
weather_data = json.loads(decompressed_data)
|
||||
|
||||
# Extrahieren der relevanten Informationen, sortiert nach stationNumber
|
||||
station_data = []
|
||||
|
||||
# Durchlaufe die Nachrichtenstruktur
|
||||
for message in weather_data.get('messages', []):
|
||||
# Es gibt eine zweite Ebene, in der die Subsets enthalten sind
|
||||
if len(message) > 1 and isinstance(message[1], list):
|
||||
for subset in message[1]:
|
||||
station_info = {}
|
||||
|
||||
# Durchlaufe das Subset, um stationNumber, Temperatur usw. zu finden
|
||||
for data_point in subset:
|
||||
if isinstance(data_point, list):
|
||||
for entry in data_point:
|
||||
if entry['key'] == 'stationNumber':
|
||||
station_info['stationNumber'] = entry['value']
|
||||
if entry['key'] == 'stationOrSiteName':
|
||||
station_info['stationName'] = entry['value']
|
||||
if entry['key'] == 'airTemperature':
|
||||
station_info['temperature'] = entry['value']
|
||||
if entry['key'] == 'dewpointTemperature':
|
||||
station_info['dewpoint'] = entry['value']
|
||||
if entry['key'] == 'relativeHumidity':
|
||||
station_info['humidity'] = entry['value']
|
||||
if entry['key'] == 'windSpeed':
|
||||
station_info['windSpeed'] = entry['value']
|
||||
|
||||
# Nur Datensätze hinzufügen, die tatsächlich Daten enthalten
|
||||
if 'stationNumber' in station_info:
|
||||
station_data.append(station_info)
|
||||
for subset in message[1]:
|
||||
station_info = {}
|
||||
for data_point in subset:
|
||||
if isinstance(data_point, list):
|
||||
# Suchen nach relevanten Schlüsseln und Werten
|
||||
for entry in data_point:
|
||||
if entry['key'] == 'stationNumber':
|
||||
station_info['stationNumber'] = entry['value']
|
||||
if entry['key'] == 'stationOrSiteName':
|
||||
station_info['stationName'] = entry['value']
|
||||
if entry['key'] == 'airTemperature':
|
||||
station_info['temperature'] = entry['value']
|
||||
if entry['key'] == 'dewpointTemperature':
|
||||
station_info['dewpoint'] = entry['value']
|
||||
if entry['key'] == 'relativeHumidity':
|
||||
station_info['humidity'] = entry['value']
|
||||
if entry['key'] == 'windSpeed':
|
||||
station_info['windSpeed'] = entry['value']
|
||||
station_data.append(station_info)
|
||||
|
||||
# Sortiere die Daten nach der StationNumber
|
||||
station_data = sorted(station_data, key=lambda x: x.get('stationNumber', 0))
|
||||
return station_data
|
||||
return []
|
||||
|
||||
|
||||
# Route für die Hauptseite
|
||||
@app.route('/')
|
||||
def index():
|
||||
@@ -64,4 +56,4 @@ def weather_data():
|
||||
return jsonify(data)
|
||||
|
||||
if __name__ == '__main__':
|
||||
app.run(host='0.0.0.0', port=5000, debug=True)
|
||||
app.run(host='0.0.0.0', port=5000)
|
||||
|
||||
Reference in New Issue
Block a user