batch-measurements-view.py

# views.py
from django.http import JsonResponse
from django.views.decorators.csrf import csrf_exempt
from django.views.decorators.http import require_POST
import json

from .models import Measurement
from .tasks import process_measurement_batch

@csrf_exempt
@require_POST
def batch_measurements(request):
    data = json.loads(request.body)
    measurements = data.get('measurements', [])
    
    # Bulk insert
    objects = [
        Measurement(
            vehicle_id=m['vehicle_id'],
            timestamp=m['timestamp'],
            d1=m['d1'],
            speed=m['speed'],
        )
        for m in measurements
    ]
    created = Measurement.objects.bulk_create(objects)
    
    # Queue for trip processing
    process_measurement_batch.delay([obj.id for obj in created])
    
    return JsonResponse({'created': len(created)})