Commands
Execute commands and manage background processes in the sandbox's isolated container environment.
Execute a command and return the complete result.
const result = await sandbox.exec(command: string, options?: ExecOptions): Promise<ExecuteResponse>Parameters:
command- The command to execute (can include arguments)options(optional):stream- Enable streaming callbacks (default:false)onOutput- Callback for real-time output:(stream: 'stdout' | 'stderr', data: string) => voidtimeout- Maximum execution time in millisecondsenv- Environment variables for this command:Record<string, string | undefined>cwd- Working directory for this commandstdin- Data to pass to the command's standard input (enables arbitrary input without shell injection risks)
Returns: Promise<ExecuteResponse> with success, stdout, stderr, exitCode
const result = await sandbox.exec("npm run build");
if (result.success) { console.log("Build output:", result.stdout);} else { console.error("Build failed:", result.stderr);}
// With streamingawait sandbox.exec("npm install", { stream: true, onOutput: (stream, data) => console.log(`[${stream}] ${data}`),});
// With environment variables (undefined values are skipped)await sandbox.exec("node app.js", { env: { NODE_ENV: "production", PORT: "3000", DEBUG_MODE: undefined, // Skipped, uses container default or unset },});
// Pass input via stdin (no shell injection risks)const result = await sandbox.exec("cat", { stdin: "Hello, world!",});console.log(result.stdout); // "Hello, world!"
// Process user input safelyconst userInput = "user@example.com\nsecret123";await sandbox.exec("python process_login.py", { stdin: userInput,});const result = await sandbox.exec('npm run build');
if (result.success) { console.log('Build output:', result.stdout);} else { console.error('Build failed:', result.stderr);}
// With streamingawait sandbox.exec('npm install', { stream: true, onOutput: (stream, data) => console.log(`[${stream}] ${data}`)});
// With environment variables (undefined values are skipped)await sandbox.exec('node app.js', { env: { NODE_ENV: 'production', PORT: '3000', DEBUG_MODE: undefined // Skipped, uses container default or unset }});
// Pass input via stdin (no shell injection risks)const result = await sandbox.exec('cat', { stdin: 'Hello, world!'});console.log(result.stdout); // "Hello, world!"
// Process user input safelyconst userInput = 'user@example.com\nsecret123';await sandbox.exec('python process_login.py', { stdin: userInput});Execute a command and return a Server-Sent Events stream for real-time processing.
const stream = await sandbox.execStream(command: string, options?: ExecOptions): Promise<ReadableStream>Parameters:
command- The command to executeoptions- Same asexec()(includingstdinsupport)
Returns: Promise<ReadableStream> emitting ExecEvent objects (start, stdout, stderr, complete, error)
import { parseSSEStream } from "@cloudflare/sandbox";
const stream = await sandbox.execStream("npm run build");
for await (const event of parseSSEStream(stream)) { switch (event.type) { case "stdout": console.log("Output:", event.data); break; case "complete": console.log("Exit code:", event.exitCode); break; case "error": console.error("Failed:", event.error); break; }}
// Stream with stdin inputconst inputStream = await sandbox.execStream( 'python -c "import sys; print(sys.stdin.read())"', { stdin: "Data from Workers!", },);
for await (const event of parseSSEStream(inputStream)) { if (event.type === "stdout") { console.log("Python received:", event.data); }}import { parseSSEStream, type ExecEvent } from '@cloudflare/sandbox';
const stream = await sandbox.execStream('npm run build');
for await (const event of parseSSEStream<ExecEvent>(stream)) { switch (event.type) { case 'stdout': console.log('Output:', event.data); break; case 'complete': console.log('Exit code:', event.exitCode); break; case 'error': console.error('Failed:', event.error); break; }}
// Stream with stdin inputconst inputStream = await sandbox.execStream('python -c "import sys; print(sys.stdin.read())"', { stdin: 'Data from Workers!'});
for await (const event of parseSSEStream<ExecEvent>(inputStream)) { if (event.type === 'stdout') { console.log('Python received:', event.data); }}Start a long-running background process.
const process = await sandbox.startProcess(command: string, options?: ProcessOptions): Promise<Process>Parameters:
command- The command to start as a background processoptions(optional):cwd- Working directoryenv- Environment variables:Record<string, string | undefined>stdin- Data to pass to the command's standard inputtimeout- Maximum execution time in millisecondsprocessId- Custom process IDencoding- Output encoding (default:'utf8')autoCleanup- Whether to clean up process on sandbox sleep
Returns: Promise<Process> object with:
id- Unique process identifierpid- System process IDcommand- The command being executedstatus- Current status ('running','exited', etc.)kill()- Stop the processgetStatus()- Get current statusgetLogs()- Get accumulated logswaitForPort()- Wait for process to listen on a portwaitForLog()- Wait for pattern in process outputwaitForExit()- Wait for process to terminate and return exit code
const server = await sandbox.startProcess("python -m http.server 8000");console.log("Started with PID:", server.pid);
// With custom environmentconst app = await sandbox.startProcess("node app.js", { cwd: "/workspace/my-app", env: { NODE_ENV: "production", PORT: "3000" },});
// Start process with stdin input (useful for interactive applications)const interactive = await sandbox.startProcess("python interactive_app.py", { stdin: "initial_config\nstart_mode\n",});const server = await sandbox.startProcess('python -m http.server 8000');console.log('Started with PID:', server.pid);
// With custom environmentconst app = await sandbox.startProcess('node app.js', { cwd: '/workspace/my-app', env: { NODE_ENV: 'production', PORT: '3000' }});
// Start process with stdin input (useful for interactive applications)const interactive = await sandbox.startProcess('python interactive_app.py', { stdin: 'initial_config\nstart_mode\n'});List all running processes.
const processes = await sandbox.listProcesses(): Promise<ProcessInfo[]>const processes = await sandbox.listProcesses();
for (const proc of processes) { console.log(`${proc.id}: ${proc.command} (PID ${proc.pid})`);}const processes = await sandbox.listProcesses();
for (const proc of processes) { console.log(`${proc.id}: ${proc.command} (PID ${proc.pid})`);}Terminate a specific process and all of its child processes.
await sandbox.killProcess(processId: string, signal?: string): Promise<void>Parameters:
processId- The process ID (fromstartProcess()orlistProcesses())signal- Signal to send (default:"SIGTERM")
Sends the signal to the entire process group, ensuring that both the main process and any child processes it spawned are terminated. This prevents orphaned processes from continuing to run after the parent is killed.
const server = await sandbox.startProcess("python -m http.server 8000");await sandbox.killProcess(server.id);
// Example with a process that spawns childrenconst script = await sandbox.startProcess( 'bash -c "sleep 10 & sleep 10 & wait"',);// killProcess terminates both sleep commands and the bash processawait sandbox.killProcess(script.id);const server = await sandbox.startProcess('python -m http.server 8000');await sandbox.killProcess(server.id);
// Example with a process that spawns childrenconst script = await sandbox.startProcess('bash -c "sleep 10 & sleep 10 & wait"');// killProcess terminates both sleep commands and the bash processawait sandbox.killProcess(script.id);Terminate all running processes.
await sandbox.killAllProcesses(): Promise<void>await sandbox.killAllProcesses();await sandbox.killAllProcesses();Stream logs from a running process in real-time.
const stream = await sandbox.streamProcessLogs(processId: string): Promise<ReadableStream>Parameters:
processId- The process ID
Returns: Promise<ReadableStream> emitting LogEvent objects
import { parseSSEStream } from "@cloudflare/sandbox";
const server = await sandbox.startProcess("node server.js");const logStream = await sandbox.streamProcessLogs(server.id);
for await (const log of parseSSEStream(logStream)) { console.log(`[${log.timestamp}] ${log.data}`);
if (log.data.includes("Server started")) break;}import { parseSSEStream, type LogEvent } from '@cloudflare/sandbox';
const server = await sandbox.startProcess('node server.js');const logStream = await sandbox.streamProcessLogs(server.id);
for await (const log of parseSSEStream<LogEvent>(logStream)) { console.log(`[${log.timestamp}] ${log.data}`);
if (log.data.includes('Server started')) break;}Get accumulated logs from a process.
const logs = await sandbox.getProcessLogs(processId: string): Promise<string>Parameters:
processId- The process ID
Returns: Promise<string> with all accumulated output
const server = await sandbox.startProcess("node server.js");await new Promise((resolve) => setTimeout(resolve, 5000));
const logs = await sandbox.getProcessLogs(server.id);console.log("Server logs:", logs);const server = await sandbox.startProcess('node server.js');await new Promise(resolve => setTimeout(resolve, 5000));
const logs = await sandbox.getProcessLogs(server.id);console.log('Server logs:', logs);All command execution methods support passing data to a command's standard input via the stdin option. This enables secure processing of user input without shell injection risks.
When you provide the stdin option:
- The input data is written to a temporary file inside the container
- The command receives this data through its standard input stream
- The temporary file is automatically cleaned up after execution
This approach prevents shell injection attacks that could occur when embedding user data directly in commands.
// Safe: User input goes through stdin, not shell parsingconst userInput = "user@domain.com; rm -rf /";const result = await sandbox.exec("python validate_email.py", { stdin: userInput,});
// Instead of unsafe: `python validate_email.py "${userInput}"`// which could execute the embedded `rm -rf /` command// Safe: User input goes through stdin, not shell parsingconst userInput = 'user@domain.com; rm -rf /';const result = await sandbox.exec('python validate_email.py', { stdin: userInput});
// Instead of unsafe: `python validate_email.py "${userInput}"`// which could execute the embedded `rm -rf /` commandProcessing form data:
const formData = JSON.stringify({ username: "john_doe", email: "john@example.com",});
const result = await sandbox.exec("python process_form.py", { stdin: formData,});const formData = JSON.stringify({ username: 'john_doe', email: 'john@example.com'});
const result = await sandbox.exec('python process_form.py', { stdin: formData});Interactive command-line tools:
// Simulate user responses to promptsconst responses = "yes\nmy-app\n1.0.0\n";const result = await sandbox.exec("npm init", { stdin: responses,});// Simulate user responses to promptsconst responses = 'yes\nmy-app\n1.0.0\n';const result = await sandbox.exec('npm init', { stdin: responses});Data transformation:
const csvData = "name,age,city\nJohn,30,NYC\nJane,25,LA";const result = await sandbox.exec("python csv_processor.py", { stdin: csvData,});
console.log("Processed data:", result.stdout);const csvData = 'name,age,city\nJohn,30,NYC\nJane,25,LA';const result = await sandbox.exec('python csv_processor.py', { stdin: csvData});
console.log('Processed data:', result.stdout);The Process object returned by startProcess() includes methods to wait for the process to be ready before proceeding.
Wait for a process to listen on a port.
await process.waitForPort(port: number, options?: WaitForPortOptions): Promise<void>Parameters:
port- The port number to checkoptions(optional):mode- Check mode:'http'(default) or'tcp'timeout- Maximum wait time in millisecondsinterval- Check interval in milliseconds (default:100)path- HTTP path to check (default:'/', HTTP mode only)status- Expected HTTP status range (default:{ min: 200, max: 399 }, HTTP mode only)
HTTP mode (default) makes an HTTP GET request and checks the response status:
const server = await sandbox.startProcess("node server.js");
// Wait for server to be ready (HTTP mode)await server.waitForPort(3000);
// Check specific endpoint and statusawait server.waitForPort(8080, { path: "/health", status: { min: 200, max: 299 }, timeout: 30000,});const server = await sandbox.startProcess('node server.js');
// Wait for server to be ready (HTTP mode)await server.waitForPort(3000);
// Check specific endpoint and statusawait server.waitForPort(8080, { path: '/health', status: { min: 200, max: 299 }, timeout: 30000});TCP mode checks if the port accepts connections:
const db = await sandbox.startProcess("redis-server");
// Wait for database to accept connectionsawait db.waitForPort(6379, { mode: "tcp", timeout: 10000,});const db = await sandbox.startProcess('redis-server');
// Wait for database to accept connectionsawait db.waitForPort(6379, { mode: 'tcp', timeout: 10000});Throws:
ProcessReadyTimeoutError- If port does not become ready within timeoutProcessExitedBeforeReadyError- If process exits before becoming ready
Wait for a pattern to appear in process output.
const result = await process.waitForLog(pattern: string | RegExp, timeout?: number): Promise<WaitForLogResult>Parameters:
pattern- String or RegExp to match in stdout/stderrtimeout- Maximum wait time in milliseconds (optional)
Returns: Promise<WaitForLogResult> with:
line- The matching line of outputmatches- Array of capture groups (for RegExp patterns)
const server = await sandbox.startProcess("node server.js");
// Wait for string patternconst result = await server.waitForLog("Server listening");console.log("Ready:", result.line);
// Wait for RegExp with capture groupsconst result = await server.waitForLog(/Server listening on port (\d+)/);console.log("Port:", result.matches[1]); // Extracted port number
// With timeoutawait server.waitForLog("Ready", 30000);const server = await sandbox.startProcess('node server.js');
// Wait for string patternconst result = await server.waitForLog('Server listening');console.log('Ready:', result.line);
// Wait for RegExp with capture groupsconst result = await server.waitForLog(/Server listening on port (\d+)/);console.log('Port:', result.matches[1]); // Extracted port number
// With timeoutawait server.waitForLog('Ready', 30000);Throws:
ProcessReadyTimeoutError- If pattern is not found within timeoutProcessExitedBeforeReadyError- If process exits before pattern appears
Wait for a process to terminate and return the exit code.
const result = await process.waitForExit(timeout?: number): Promise<WaitForExitResult>Parameters:
timeout- Maximum wait time in milliseconds (optional)
Returns: Promise<WaitForExitResult> with:
exitCode- The process exit code
const build = await sandbox.startProcess("npm run build");
// Wait for build to completeconst result = await build.waitForExit();console.log("Build finished with exit code:", result.exitCode);
// With timeoutconst result = await build.waitForExit(60000); // 60 second timeoutconst build = await sandbox.startProcess('npm run build');
// Wait for build to completeconst result = await build.waitForExit();console.log('Build finished with exit code:', result.exitCode);
// With timeoutconst result = await build.waitForExit(60000); // 60 second timeoutThrows:
ProcessReadyTimeoutError- If process does not exit within timeout
- Background processes guide - Managing long-running processes
- Files API - File operations