michi.vonah/bbzw-horizon
1
0
Fork 0
mirror of https://github.com/michivonah/bbzw-horizon.git synced 2025-12-22 17:16:27 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

timerange added to get-data endpoint

Browse source
This commit is contained in:
Michi 2025-04-09 10:45:47 +02:00
parent 2c1a95c1a5
commit 12a1dcfa2d
1 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
webservice/webservice.py
View file

@ -14,7 +14,7 @@ app = FastAPI(
title="BBZW-Horizon", title="BBZW-Horizon",
description="BBZW-Horizon ist ein Tool, welches entwickelt wurde, um durch die Erfassung und Auswertung von Luftqualitätsmesswerten die Luftqualität in den Schulzimmern des BBZW Sursee zu verbessern. Bei dieser API handelt es sich um die Kommunikationsschnittstelle, zwischen den Arduinos, welche mit Sensoren die Daten erfassen und an die API senden. Diese API speichert die Daten dann in der Datenbank, damit diese durch das Frontend abgerufen und visualisiert werden können.", description="BBZW-Horizon ist ein Tool, welches entwickelt wurde, um durch die Erfassung und Auswertung von Luftqualitätsmesswerten die Luftqualität in den Schulzimmern des BBZW Sursee zu verbessern. Bei dieser API handelt es sich um die Kommunikationsschnittstelle, zwischen den Arduinos, welche mit Sensoren die Daten erfassen und an die API senden. Diese API speichert die Daten dann in der Datenbank, damit diese durch das Frontend abgerufen und visualisiert werden können.",
summary="Die BBZW-Horizon API dient als Kommunikationsschnittstelle, um Luftqualitätsmesswerte von Arduinos, die mit Sensoren ausgestattet sind, zu erfassen", summary="Die BBZW-Horizon API dient als Kommunikationsschnittstelle, um Luftqualitätsmesswerte von Arduinos, die mit Sensoren ausgestattet sind, zu erfassen",
version="0.0.2" version="0.0.3"
) )
# DB Session # DB Session
@ -82,11 +82,12 @@ async def generate_token(
# Rückgabe des Tokens und des Ablaufdatums # Rückgabe des Tokens und des Ablaufdatums
return TokenResponse(token=new_token, validuntil=valid_until) return TokenResponse(token=new_token, validuntil=valid_until)
@app.get("/sensors/recent-data", response_model=List[SensorData], tags=["sensors"]) @app.get("/sensors/get-data", response_model=List[SensorData], tags=["sensors"])
async def get_recent_sensor_data_endpoint( async def get_recent_sensor_data_endpoint(
client: str, client: str,
token: str = Header(...), # Token aus dem Header lesen token: str = Header(...), # Token aus dem Header lesen
end_date: Optional[datetime] = Query(None), # Optionales Datum-Parameter start_date: Optional[datetime] = Query(None), # Optionales Startdatum
end_date: Optional[datetime] = Query(None), # Optionales Enddatum
db: Session = Depends(get_db) db: Session = Depends(get_db)
): ):
# Authentifiziere den Benutzer # Authentifiziere den Benutzer
@ -98,15 +99,16 @@ async def get_recent_sensor_data_endpoint(
if client_id is None: if client_id is None:
raise HTTPException(status_code=404, detail="Client not found") raise HTTPException(status_code=404, detail="Client not found")
# Setze den end_date auf heute, falls keiner übergeben wird # Setze das end_date auf heute, falls keines übergeben wird
if end_date is None: if end_date is None:
end_date = datetime.now() end_date = datetime.now()
# Berechne den Startzeitpunkt (24 Stunden vor dem end_date) # Setze das start_date auf 24 Stunden vor dem end_date, falls keines übergeben wird
start_time = end_date - timedelta(days=1) if start_date is None:
start_date = end_date - timedelta(days=1)
# Hole die Sensordaten im angegebenen Zeitraum # Hole die Sensordaten im angegebenen Zeitraum
recent_data = get_recent_sensor_data(db, client_id, start_time, end_date) recent_data = get_recent_sensor_data(db, client_id, start_date, end_date)
if not recent_data: if not recent_data:
raise HTTPException(status_code=404, detail="No sensor data found in the specified time range.") raise HTTPException(status_code=404, detail="No sensor data found in the specified time range.")