// Create download link const url = window.URL.createObjectURL(new Blob([response.data])); const link = document.createElement('a'); link.href = url; const contentDisposition = response.headers['content-disposition']; let filename = 'download.vmdk'; if (contentDisposition) const match = contentDisposition.match(/filename="(.+)"/); if (match) filename = match[1]; link.setAttribute('download', filename); document.body.appendChild(link); link.click(); link.remove(); window.URL.revokeObjectURL(url); // Clean up after download await axios.delete(`/api/v1/download/cleanup/$taskId`); // Remove task from active tasks setActiveTasks(prev => const newMap = new Map(prev); newMap.delete(taskId); return newMap; ); catch (error) console.error('Download failed:', error);
celery_worker: build: context: . dockerfile: Dockerfile.celery environment: - REDIS_URL=redis://redis:6379/0 - DATABASE_URL=postgresql://vmdk_user:secure_password@postgres/vmdk_downloads volumes: - /tmp:/tmp # For downloaded files - ./certs:/certs # For SSL certificates depends_on: - redis - postgres command: celery -A vmdk_download_service.celery_app worker --loglevel=info how to download vmdk file from datastore
# Submit celery task task = download_vmdk_task.delay(request.dict()) return DownloadTaskResponse( task_id=task.id, status="pending", message="Download task submitted successfully" ) except Exception as e: raise HTTPException(status_code=500, detail=str(e)) @app.get("/api/v1/download/status/task_id") async def get_download_status(task_id: str): """Get download task status""" task = download_vmdk_task.AsyncResult(task_id) // Create download link const url = window