modified: app.py
modified: templates/index.html
This commit is contained in:
SimolZimol
87
app.py
87
app.py
@@ -5,52 +5,57 @@ from flask import Flask, jsonify, render_template
|
||||
|
||||
app = Flask(__name__)
|
||||
|
||||
# URL zur Datei
|
||||
DATA_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 Abrufen und Entpacken der Daten
|
||||
def fetch_weather_data():
|
||||
response = requests.get(DATA_URL)
|
||||
# Funktion, um die bz2-Datei herunterzuladen und zu entpacken
|
||||
def download_and_extract_data():
|
||||
url = "https://opendata.dwd.de/weather/weather_reports/synoptic/germany/json/Z__C_EDZW_latest_bda01,synop_bufr_GER_999999_999999__MW_XXX.json.bz2"
|
||||
|
||||
# Lade die bz2-Datei herunter
|
||||
response = requests.get(url)
|
||||
if response.status_code == 200:
|
||||
# Entpacken der BZ2-Datei
|
||||
# Entpacke die bz2-Datei
|
||||
decompressed_data = bz2.decompress(response.content)
|
||||
weather_data = json.loads(decompressed_data)
|
||||
return json.loads(decompressed_data)
|
||||
else:
|
||||
return None
|
||||
|
||||
# Funktion, um die Wetterdaten nach Station zu sortieren
|
||||
def extract_and_sort_weather_data():
|
||||
data = download_and_extract_data()
|
||||
if data:
|
||||
weather_data = []
|
||||
# Extrahiere die Wetterdaten, die nach 'stationNumber' sortiert werden
|
||||
for message in data.get('messages', []):
|
||||
for station_data in message[1:]:
|
||||
weather_info = {}
|
||||
for item in station_data:
|
||||
if isinstance(item, dict):
|
||||
if item['key'] == 'stationNumber':
|
||||
weather_info['stationNumber'] = item['value']
|
||||
elif item['key'] == 'stationOrSiteName':
|
||||
weather_info['stationName'] = item['value']
|
||||
elif item['key'] == 'airTemperature':
|
||||
weather_info['airTemperature'] = item['value'] - 273.15 # Kelvin to Celsius
|
||||
elif item['key'] == 'windSpeed':
|
||||
weather_info['windSpeed'] = item['value']
|
||||
elif item['key'] == 'pressureReducedToMeanSeaLevel':
|
||||
weather_info['pressure'] = item['value']
|
||||
elif item['key'] == 'relativeHumidity':
|
||||
weather_info['humidity'] = item['value']
|
||||
|
||||
if 'stationNumber' in weather_info:
|
||||
weather_data.append(weather_info)
|
||||
|
||||
# Liste zur Speicherung der Stationsnummern
|
||||
station_numbers = []
|
||||
# Sortiere die Wetterdaten nach 'stationNumber'
|
||||
sorted_weather_data = sorted(weather_data, key=lambda x: x['stationNumber'])
|
||||
return sorted_weather_data
|
||||
else:
|
||||
return []
|
||||
|
||||
# Durchlaufen der Nachrichten und ihrer Untergruppen
|
||||
for message in weather_data.get('messages', []):
|
||||
# Überprüfen, ob der Eintrag eine Liste ist und Daten enthält
|
||||
if isinstance(message, list) and len(message) > 1 and isinstance(message[1], list):
|
||||
for subset in message[1]:
|
||||
# Durchlaufen der Datenpunkte in jeder Subgruppe
|
||||
if isinstance(subset, list):
|
||||
for data_point in subset:
|
||||
if isinstance(data_point, list):
|
||||
for entry in data_point:
|
||||
# Nur die "stationNumber" extrahieren
|
||||
if entry.get('key') == 'stationNumber':
|
||||
station_numbers.append(entry.get('value'))
|
||||
|
||||
# Rückgabe der gefundenen stationNumbers
|
||||
return station_numbers
|
||||
|
||||
# Rückgabe einer leeren Liste, falls keine Daten gefunden wurden
|
||||
return []
|
||||
|
||||
|
||||
|
||||
# Route für die Hauptseite
|
||||
# Flask-Route, um die Wetterdaten anzuzeigen
|
||||
@app.route('/')
|
||||
def index():
|
||||
return render_template('index.html')
|
||||
|
||||
# API-Route, um die Wetterdaten abzurufen
|
||||
@app.route('/weather_data')
|
||||
def weather_data():
|
||||
data = fetch_weather_data()
|
||||
return jsonify(data)
|
||||
def weather():
|
||||
weather_data = extract_and_sort_weather_data()
|
||||
return render_template('index.html', weather_data=weather_data)
|
||||
|
||||
if __name__ == '__main__':
|
||||
app.run(host='0.0.0.0', port=5000)
|
||||
|
||||
@@ -3,80 +3,49 @@
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Wetterdaten nach Stationen</title>
|
||||
<title>Wetterdaten</title>
|
||||
<style>
|
||||
body {
|
||||
font-family: Arial, sans-serif;
|
||||
text-align: center;
|
||||
margin: 0;
|
||||
padding: 20px;
|
||||
background-color: #f4f4f4;
|
||||
}
|
||||
|
||||
table {
|
||||
width: 100%;
|
||||
border-collapse: collapse;
|
||||
margin: 20px 0;
|
||||
}
|
||||
|
||||
table, th, td {
|
||||
border: 1px solid black;
|
||||
}
|
||||
|
||||
th, td {
|
||||
padding: 10px;
|
||||
text-align: center;
|
||||
padding: 8px;
|
||||
text-align: left;
|
||||
}
|
||||
|
||||
th {
|
||||
background-color: #007BFF;
|
||||
color: white;
|
||||
background-color: #f2f2f2;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
<h1>Wetterdaten nach Stationen</h1>
|
||||
<h1>Wetterdaten sortiert nach Station</h1>
|
||||
<table>
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Station Nummer</th>
|
||||
<th>Station Name</th>
|
||||
<th>Temperatur (K)</th>
|
||||
<th>Taupunkt (K)</th>
|
||||
<th>Relative Luftfeuchtigkeit (%)</th>
|
||||
<th>Stationsnummer</th>
|
||||
<th>Stationsname</th>
|
||||
<th>Temperatur (°C)</th>
|
||||
<th>Windgeschwindigkeit (m/s)</th>
|
||||
<th>Luftdruck (Pa)</th>
|
||||
<th>Luftfeuchtigkeit (%)</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody id="weather-table-body">
|
||||
<!-- Daten werden hier geladen -->
|
||||
<tbody>
|
||||
{% for data in weather_data %}
|
||||
<tr>
|
||||
<td>{{ data.stationNumber }}</td>
|
||||
<td>{{ data.stationName }}</td>
|
||||
<td>{{ data.airTemperature }}</td>
|
||||
<td>{{ data.windSpeed }}</td>
|
||||
<td>{{ data.pressure }}</td>
|
||||
<td>{{ data.humidity }}</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
|
||||
<script>
|
||||
async function fetchWeatherData() {
|
||||
const response = await fetch('/weather_data');
|
||||
const data = await response.json();
|
||||
const tableBody = document.getElementById('weather-table-body');
|
||||
tableBody.innerHTML = ''; // Tabelle leeren
|
||||
|
||||
data.forEach(station => {
|
||||
const row = document.createElement('tr');
|
||||
|
||||
row.innerHTML = `
|
||||
<td>${station.stationNumber || 'N/A'}</td>
|
||||
<td>${station.stationName || 'N/A'}</td>
|
||||
<td>${station.temperature ? station.temperature.toFixed(2) : 'N/A'}</td>
|
||||
<td>${station.dewpoint ? station.dewpoint.toFixed(2) : 'N/A'}</td>
|
||||
<td>${station.humidity ? station.humidity.toFixed(2) : 'N/A'}</td>
|
||||
<td>${station.windSpeed ? station.windSpeed.toFixed(2) : 'N/A'}</td>
|
||||
`;
|
||||
|
||||
tableBody.appendChild(row);
|
||||
});
|
||||
}
|
||||
|
||||
// Wetterdaten laden, sobald die Seite geladen ist
|
||||
window.onload = fetchWeatherData;
|
||||
</script>
|
||||
</body>
|
||||
</html>
|
||||
|
||||
Reference in New Issue
Block a user