70 lines
2.7 KiB
Python
70 lines
2.7 KiB
Python
import requests
|
|
import bz2
|
|
import json
|
|
from flask import Flask, jsonify, render_template
|
|
|
|
app = Flask(__name__)
|
|
|
|
# URL zur komprimierten Wetterdatei
|
|
url = "https://opendata.dwd.de/weather/weather_reports/synoptic/germany/json/Z__C_EDZW_latest_bda01%2Csynop_bufr_GER_999999_999999__MW_XXX.json.bz2"
|
|
|
|
# Funktion zum Herunterladen und Entpacken der bz2-Datei
|
|
def download_and_extract(url):
|
|
response = requests.get(url)
|
|
if response.status_code == 200:
|
|
compressed_content = response.content
|
|
decompressed_content = bz2.decompress(compressed_content)
|
|
return decompressed_content
|
|
else:
|
|
return None
|
|
|
|
# Funktion zum Extrahieren der relevanten Wetterdaten
|
|
def extract_weather_data(messages):
|
|
weather_info = []
|
|
|
|
# Iteriere durch jede Nachricht (jeder Block enthält die Daten einer Wetterstation)
|
|
for message in messages:
|
|
station_info = {}
|
|
|
|
# Iteriere durch die Schlüssel-Wert-Paare in jeder Nachricht
|
|
for item in message:
|
|
if isinstance(item, list):
|
|
for subitem in item:
|
|
if isinstance(subitem, dict):
|
|
# Extrahiere die Stationsinformationen
|
|
if subitem.get('key') == "stationOrSiteName":
|
|
station_info['station'] = subitem.get('value')
|
|
elif subitem.get('key') == "airTemperature":
|
|
station_info['temperature'] = subitem.get('value') - 273.15 # Umrechnung von Kelvin in Celsius
|
|
elif subitem.get('key') == "pressureReducedToMeanSeaLevel":
|
|
station_info['pressure'] = subitem.get('value') / 100 # Umrechnung in hPa
|
|
elif subitem.get('key') == "windSpeed":
|
|
station_info['wind_speed'] = subitem.get('value')
|
|
elif subitem.get('key') == "cloudCoverTotal":
|
|
station_info['cloud_cover'] = subitem.get('value')
|
|
|
|
# Wenn wir Informationen für diese Station gefunden haben, fügen wir sie zur Liste hinzu
|
|
if station_info:
|
|
weather_info.append(station_info)
|
|
|
|
return weather_info
|
|
|
|
# API-Route zum Bereitstellen der Wetterdaten
|
|
@app.route('/weather')
|
|
def weather():
|
|
data = download_and_extract(url)
|
|
if data:
|
|
weather_data = json.loads(data)
|
|
extracted_data = extract_weather_data(weather_data['messages'])
|
|
return jsonify(extracted_data)
|
|
else:
|
|
return jsonify({"error": "Fehler beim Abrufen der Wetterdaten"}), 500
|
|
|
|
# Route für die Website
|
|
@app.route('/')
|
|
def index():
|
|
return render_template('index.html')
|
|
|
|
if __name__ == '__main__':
|
|
app.run(host='0.0.0.0', port=5000)
|