This commit is contained in:
no
2024-11-29 14:25:23 +01:00
parent f47f09409c
commit b3f0c0b0bd
2 changed files with 71 additions and 110 deletions
-9
View File
@@ -5,21 +5,17 @@ fuenf_minuten_bp = Blueprint('fuenf_minuten', __name__, url_prefix='/fuenf_minut
@fuenf_minuten_bp.route('/', strict_slashes=False)
def fuenf_minuten():
# Abrufen der Filterparameter aus der Anfrage
start_date = request.args.get('start_date')
end_date = request.args.get('end_date')
start_time = request.args.get('start_time', '00:00')
end_time = request.args.get('end_time', '23:59')
# Validierung der Eingabewerte
if not start_date or not end_date:
return jsonify({'error': 'Bitte sowohl Start- als auch End-Datum auswählen.'})
# Aufbau der Verbindung zur Datenbank
conn = get_db_connection()
cursor = conn.cursor()
# SQL-Abfrage zur Generierung der 5-Minuten-Intervalle und Zählung der Übertragungen
query = """
WITH RECURSIVE seq AS (
SELECT 0 AS n
@@ -43,12 +39,10 @@ def fuenf_minuten():
ORDER BY all_times.time_slot;
"""
# Setzen der Parameter für die SQL-Abfrage
start_datetime = f"{start_date} {start_time}"
end_datetime = f"{end_date} {end_time}"
try:
# Ausführen der SQL-Abfrage
cursor.execute(query, (
start_datetime,
end_datetime,
@@ -59,11 +53,8 @@ def fuenf_minuten():
))
results = cursor.fetchall()
conn.close()
# Formatierung der Ergebnisse für die API-Antwort
return jsonify([{'time_slot': row[0], 'transmission_count': row[1]} for row in results])
except Exception as e:
# Fehlerbehandlung
conn.close()
return jsonify({'error': str(e)})