javascript 54 lines · 9 steps

Streaming a CSV export in a Next.js route

A Next.js GET handler streams database rows into a downloadable CSV without buffering the whole result in memory.

Explained by highlit
Next.js Advanced streaming csv readablestream backpressure route-handler
1import { NextResponse } from 'next/server';
2import { db } from '@/lib/db';
3 
4function csvCell(value) {
5 if (value == null) return '';
6 const str = String(value);
7 return /[",\n]/.test(str) ? `"${str.replace(/"/g, '""')}"` : str;
8}
9 
10export async function GET(request) {
11 const { searchParams } = new URL(request.url);
12 const status = searchParams.get('status') ?? 'active';
13 const since = searchParams.get('since');
14 
15 const cursor = db.orders.stream({
16 where: {
17 status,
18 ...(since ? { createdAt: { gte: new Date(since) } } : {}),
19 },
20 orderBy: { createdAt: 'asc' },
21 });
22 
23 const columns = ['id', 'customerEmail', 'total', 'status', 'createdAt'];
24 const encoder = new TextEncoder();
25 
26 const stream = new ReadableStream({
27 async start(controller) {
28 controller.enqueue(encoder.encode(columns.join(',') + '\n'));
29 try {
30 for await (const order of cursor) {
31 const row = columns.map((col) => csvCell(order[col])).join(',');
32 controller.enqueue(encoder.encode(row + '\n'));
33 }
34 } catch (err) {
35 controller.error(err);
36 return;
37 }
38 controller.close();
39 },
40 cancel() {
41 cursor.return?.();
42 },
43 });
44 
45 const filename = `orders-${status}-${new Date().toISOString().slice(0, 10)}.csv`;
46 
47 return new NextResponse(stream, {
48 headers: {
49 'Content-Type': 'text/csv; charset=utf-8',
50 'Content-Disposition': `attachment; filename="${filename}"`,
51 'Cache-Control': 'no-store',
52 },
53 });
54}
01 / 01
STEP 01

Walkthrough

Space play ←→ step click any line
Three takeaways
  1. 1Streaming rows one at a time keeps memory flat no matter how large the export grows.
  2. 2CSV cells must escape quotes, commas, and newlines to stay parseable.
  3. 3A stream's cancel hook lets you release the database cursor when the client disconnects.

Related explainers

javascript 
import { useReducer, useCallback } from 'react';
 
function historyReducer(state, action) {
  const { past, present, future } = state;

Undo/redo form state with a React reducer

undo-redo reducer immutability
Intermediate 10 steps
python 
import hashlib
from collections import defaultdict
from pathlib import Path
 

Finding duplicate files by size then hash

hashing file-io deduplication
Intermediate 7 steps
javascript 
class MovingAverage {
  constructor(windowSize) {
    if (!Number.isInteger(windowSize) || windowSize <= 0) {
      throw new RangeError('windowSize must be a positive integer');

A rolling average over a fixed window

circular-buffer streaming async-generators
Intermediate 7 steps
javascript 
const { Pool } = require('pg');
 
const pool = new Pool({
  connectionString: process.env.DATABASE_URL,

Per-request Postgres connections in Express

connection-pooling middleware transactions
Intermediate 8 steps
java 
public class RequestThrottler {
 
    private final Semaphore permits;
    private final long acquireTimeoutMillis;

Bounding concurrency with a Semaphore in Java

concurrency semaphore rate-limiting
Intermediate 6 steps
javascript 
const express = require('express');
const router = express.Router();
const db = require('../db');
 

Building a paginated orders page in Express

pagination routing sql-queries
Intermediate 7 steps

Share this explainer

Here's the card — post it anywhere.

Streaming a CSV export in a Next.js route — share card
Made with highlit — turn any snippet into a walkthrough like this in about a minute.
Explain your code