File processing
Store each upload immediately, queue the processing work, and run document, image, CSV, or AI tasks asynchronously.
Synchronous upload handler
RocketStack workflow
Store the original upload before processing begins.
Hold processing jobs until a Function is ready to run them.
Download the object, perform the processing work, and store or return the result.
Example workflow
Run an illustrative upload and processing sequence. Selected files stay in the browser — nothing is uploaded to RocketStack in this demo.
Example workflow
Drag and drop a file here, or choose one with the file picker.
Select a sample file or choose a local file to begin.
Use the RocketStack HTTP API or generated SDKs. Examples below use real request fields.
Step 1 of 4
Upload the file
Language
Store the original file and capture its RocketStack object path.
const form = new FormData();
form.append('file', file);
form.append('path', `uploads/${file.name}`);
const uploadRes = await fetch('https://api.rocketstack.sh/storage/objects', {
method: 'POST',
headers: {
Authorization: `Bearer ${process.env.ROCKETSTACK_API_KEY}`
},
body: form
});
const { data } = await uploadRes.json();
// data.path, data.sizeBytes, data.contentType, data.etag
console.log(data.path);Ready to process your first file?
Also see Object Storage, Queue and Functions product docs.
Keep your application where it is. Upload files and enqueue processing from server-side code.
Keep your Next.js frontend and routes. Send files and processing jobs to RocketStack from server-side application code.
// app/api/uploads/route.ts — server-side only (keep API key off the client)
export async function POST(request: Request) {
const formData = await request.formData()
const file = formData.get('file') as File
const path = `uploads/${file.name}`
const uploadForm = new FormData()
uploadForm.append('file', file)
uploadForm.append('path', path)
const uploadRes = await fetch('https://api.rocketstack.sh/storage/objects', {
method: 'POST',
headers: { Authorization: `Bearer ${process.env.ROCKETSTACK_API_KEY}` },
body: uploadForm
})
const { data } = await uploadRes.json()
await fetch(
`https://api.rocketstack.sh/queues/${process.env.ROCKETSTACK_QUEUE_ID}/messages`,
{
method: 'POST',
headers: {
Authorization: `Bearer ${process.env.ROCKETSTACK_API_KEY}`,
'Content-Type': 'application/json'
},
body: JSON.stringify({
payload: {
type: 'file.uploaded',
objectPath: data.path,
operation: 'parse-csv'
},
idempotencyKey: data.path
})
}
)
return Response.json({ accepted: true, path: data.path }, { status: 202 })
}Related reading: Use RocketStack with Next.js
Next.js starter
Clone a Next.js application with secure uploads, RocketStack Object Storage, Queue integration, and asynchronous Function processing.
Principle 1
Preserve the original file before starting transformations or external API calls.
Principle 2
Associate each processing job with the file path and a stable job or upload ID.
Principle 3
A retried job should not create duplicate result files, notifications, or application records.
Principle 4
Invalid files should be surfaced for review rather than retried indefinitely. After maxReceiveCount (default 10), messages move to a dead-letter queue.
Use RocketStack MCP to create the Storage, Queue, Function, and application integration behind the workflow. This workflow uses Object Storage, Queue, and Functions.
Add asynchronous file processing to this application using RocketStack.
Requirements:
- Accept file uploads through the existing server-side application
- Store each original file in RocketStack Object Storage
- Add a processing job to a RocketStack Queue
- Include the stored object path and job metadata in the queued payload
- Deploy a RocketStack Function to process each queued file
- Make processing safe to retry
- Store or return the processing result using supported RocketStack APIs
- Surface failures clearly
- Keep the RocketStack API key in server-side environment variablesEvery RocketStack primitive is available on Free with lower monthly usage allowances.
PRIVATE ALPHA
Bring a real application, complete the setup during a guided session, and help shape the product.
Apply for the alphaCreate a free account and deploy the Object Storage, Queue, and Function behind your first processing workflow.