We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 55b392a commit 855aec9Copy full SHA for 855aec9
src/websocket/sockets.py
@@ -73,11 +73,13 @@ def process_drone_update(data: dict) -> None:
73
from drone.models import DroneTelemetry
74
from drone.serializers import DroneTelemetrySerializer
75
76
+ # Validate telemetry data
77
telemetry = DroneTelemetrySerializer(data=data)
78
telemetry.is_valid(raise_exception=True)
79
80
telemetry.save()
81
82
+ # Drop records older than 5 minutes
83
cutoff_time = (datetime.now() - timedelta(minutes=5)).timestamp()
84
old_records = DroneTelemetry.objects.filter(timestamp__lt=int(cutoff_time))
85
old_records.delete()
0 commit comments