README.md 9.8 KB
Newer Older
Yan Ru Pei's avatar
Yan Ru Pei committed
1
<!-- # SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
2
# SPDX-License-Identifier: Apache-2.0 -->
Yan Ru Pei's avatar
Yan Ru Pei committed
3
4
5
6
7
8
9
10

# Router Benchmarking Guide

This directory contains scripts for benchmarking the Dynamo router with prefix caching. The benchmarks measure performance improvements from prefix sharing across requests.

## Prerequisites

- NVIDIA GPUs (8 GPUs for default configuration)
11
- (optional) H100 GPUs or later for gpt-oss-120b examples
Yan Ru Pei's avatar
Yan Ru Pei committed
12
13
14
15
16
17
- CUDA environment properly configured
- etcd and NATS running (required for Dynamo coordination)
- Required Python packages:
  - `dynamo` package (with vllm and frontend modules)
  - `genai-perf` for benchmarking
  - `matplotlib` for plotting results
18
  - `data-generator` package (install with `pip install -e ./benchmarks` from repo root)
Yan Ru Pei's avatar
Yan Ru Pei committed
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

### Setting up etcd and NATS

This benchmark requires etcd and NATS. To quickly set them up, run:

```bash
# From the repository root:
docker compose -f deploy/docker-compose.yml up -d
```

This will start both etcd and NATS with the required configurations in the background.

## Scripts Overview

- **`run_engines.sh`** - Launches multiple vLLM worker instances
- **`ping.sh`** - Simple test script to verify the setup is working
- **`prefix_ratio_benchmark.py`** - Main benchmarking script that sweeps prefix ratios
36
- **`real_data_benchmark.py`** - Benchmarking script that uses real mooncake-style trace data
Yan Ru Pei's avatar
Yan Ru Pei committed
37
38
39
40
- **`plot_prefix_ratio_comparison.py`** - Generates comparison plots from benchmark results

## Usage Instructions

41
### Step 1: Launch Workers
Yan Ru Pei's avatar
Yan Ru Pei committed
42

43
44
45
46
47
48
Make sure you have 8 GPUs for these examples, unless you are using mockers (see below). First, start the worker engines in a terminal.

The script supports three modes:
- **`agg` (default)**: Aggregated/monolithic workers that handle both prefill and decode
- **`decode`**: Workers dedicated to decode (token generation) phase
- **`prefill`**: Workers dedicated to prefill (prompt processing) phase
Yan Ru Pei's avatar
Yan Ru Pei committed
49
50

```bash
51
# Default: 8 aggregated workers with DeepSeek model (handles both prefill and decode)
Yan Ru Pei's avatar
Yan Ru Pei committed
52
53
54
55
./run_engines.sh \
    --num-workers 8 \
    --model-path deepseek-ai/DeepSeek-R1-Distill-Llama-8B

56
# Example: 4 workers with larger model using tensor parallelism (2 GPUs per worker)
57
# NOTE: this requires having Hopper or later GPU SKUs to support MXFP4 precision.
Yan Ru Pei's avatar
Yan Ru Pei committed
58
59
60
61
62
63
./run_engines.sh \
    --num-workers 4 \
    --model-path openai/gpt-oss-120b \
    --tensor-parallel-size 2
```

64
#### Disaggregated Serving (Decode + Prefill Workers)
Yan Ru Pei's avatar
Yan Ru Pei committed
65

66
You can launch separate decode and prefill workers for disaggregated serving. This allows you to dedicate specific GPUs to prefill (prompt processing) and decode (token generation) tasks:
Yan Ru Pei's avatar
Yan Ru Pei committed
67
68
69
70

```bash
# Launch 4 decode workers (GPUs 0-3)
./run_engines.sh \
71
    --decode \
Yan Ru Pei's avatar
Yan Ru Pei committed
72
73
74
75
76
    --num-workers 4 \
    --model-path deepseek-ai/DeepSeek-R1-Distill-Llama-8B

# Launch 4 prefill workers (GPUs 4-7)
./run_engines.sh \
77
    --prefill \
Yan Ru Pei's avatar
Yan Ru Pei committed
78
79
80
81
82
    --num-workers 4 \
    --base-gpu-offset 4 \
    --model-path deepseek-ai/DeepSeek-R1-Distill-Llama-8B
```

Yan Ru Pei's avatar
Yan Ru Pei committed
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
#### Alternative: Launch vLLM Mock Workers

We also supports running lightweight mock engines that simulate vLLM behavior without performing actual model inference. Mocker engines are useful for testing router logic and performance without GPU requirements. Use the `--mockers` flag to run mocker engines instead of real vLLM workers.

```bash
# Example: Running mocker engines for testing (no GPU required)
./run_engines.sh --mockers \
    --num-workers 8 \
    --model-path deepseek-ai/DeepSeek-R1-Distill-Llama-8B \
    --block-size 64 \
    --speedup-ratio 2.0
```

**Note**: The `--speedup-ratio` parameter controls the inference speed of mocker engines. A higher value (e.g., 2.0) makes the mocker engines simulate faster inference, allowing benchmarks to complete more quickly. This is particularly useful for testing router performance without waiting for realistic inference times.

### Step 2: Start the Router

In a **new terminal**, launch the Dynamo router using the Python CLI:

```bash
python -m dynamo.frontend \
    --router-mode kv \
    --router-reset-states \
    --http-port 8000
```

This starts the router with:
- KV cache routing mode
- `--router-reset-states` flag to clear the event cache (JetStream) from previous runs (useful for single router benchmarking)
- HTTP port 8000

To see all available router arguments, run:
```bash
python -m dynamo.frontend --help
```

For detailed explanations of router arguments (especially KV cache routing parameters), see the [KV Cache Routing documentation](../../docs/architecture/kv_cache_routing.md).

121
#### Launching a Standalone Router for Prefill Workers (Optional)
Yan Ru Pei's avatar
Yan Ru Pei committed
122

123
If you're using disaggregated serving with separate prefill and decode workers, you should also launch a standalone router for prefill workers. This router handles routing prefill requests to dedicated prefill workers. When using a standalone prefill router, it's recommended to start the frontend (decode router) with `--kv-overlap-score-weight 0` for pure load balancing (as prefix-aware routing is now handled by the standalone router):
Yan Ru Pei's avatar
Yan Ru Pei committed
124
125
126
127
128
129
130
131
132

```bash
# Start the decode router with pure load balancing
python -m dynamo.frontend \
    --router-mode kv \
    --router-reset-states \
    --http-port 8000 \
    --kv-overlap-score-weight 0

133
134
135
136
137
138
# In another terminal, start the standalone router for prefill workers
python -m dynamo.router \
    --endpoint dynamo.prefill.generate \
    --block-size 64 \
    --router-reset-states \
    --no-track-active-blocks
Yan Ru Pei's avatar
Yan Ru Pei committed
139
140
```

141
The `--router-reset-states` flag clears any previous state, and `--no-track-active-blocks` disables active block tracking (suitable for prefill-only routing where decode load is not relevant).
Yan Ru Pei's avatar
Yan Ru Pei committed
142

Yan Ru Pei's avatar
Yan Ru Pei committed
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
**Note**: If you're unsure whether your backend engines correctly emit KV events for certain models (e.g., hybrid models like gpt-oss or nemotron nano 2), use the `--no-kv-events` flag to disable KV event tracking and use approximate KV indexing instead:

```bash
python -m dynamo.frontend \
    --router-mode kv \
    --http-port 8000 \
    --no-kv-events
```

### Step 3: Verify Setup

In another terminal, test that everything is working:

```bash
./ping.sh
# Or specify a different port:
./ping.sh 8000
```

This sends a simple test request to the router. You should see a streamed response if everything is configured correctly.

### Step 4: Run Benchmarks

Once the setup is verified, run the prefix ratio benchmark:

```bash
python prefix_ratio_benchmark.py
```

Default configuration:
- Tests prefix ratios: 0.5 (can be customized with `--prefix-ratios 0.1 0.3 0.5 0.7 0.9`)
- Input sequence length: 14000 tokens
- Output sequence length: 200 tokens
- Requests: 200
- Concurrency: 20

You can customize the benchmark:

```bash
# Test multiple prefix ratios
python prefix_ratio_benchmark.py --prefix-ratios 0.1 0.3 0.5 0.7 0.9

# Adjust input/output lengths
python prefix_ratio_benchmark.py --isl 10000 --osl 500

# Change request count and concurrency
python prefix_ratio_benchmark.py --requests 500 --concurrency 50

# Use multiple router endpoints for parallel benchmarking (for testing multiple Router replicas)
python prefix_ratio_benchmark.py --url http://localhost:8000 http://localhost:8001

# Specify output directory
python prefix_ratio_benchmark.py --output-dir results/experiment1
```

198
### Step 4 (Alternative): Run Benchmarks with Real Trace Data
Yan Ru Pei's avatar
Yan Ru Pei committed
199

200
Instead of synthetic benchmarks with controlled prefix ratios, you can benchmark using real trace data in [mooncake-style format](https://github.com/kvcache-ai/Mooncake/blob/d21da178bae8db9651cf18a76824c084145fc725/mooncake_trace.jsonl). This approach uses actual request patterns from production traces, potentially modified with synthesis parameters.
Yan Ru Pei's avatar
Yan Ru Pei committed
201

202
```bash
203
python real_data_benchmark.py --input-dataset mooncake_trace.jsonl
204
205
```

206
The script can apply various modifications on top of the original trace dataset to simulate different scenarios and workload conditions. This script accepts the same synthesis parameters as the [prefix data generator](../prefix_data_generator/README.md):
Yan Ru Pei's avatar
Yan Ru Pei committed
207

208
209
210
211
212
213
214
**Key parameters:**
- `--num-requests`: Number of requests to synthesize from the trace (default: use all)
- `--speedup-ratio`: Speed up request arrival times (e.g., 2.0 makes requests arrive 2x faster)
- `--prefix-len-multiplier`: Scale the length of shared prefixes (e.g., 2.0 doubles prefix lengths)
- `--prefix-root-multiplier`: Replicate the prefix tree structure N times with different roots
- `--prompt-len-multiplier`: Scale the length of unique user prompts (e.g., 0.5 for shorter prompts)
- `--max-isl`: Filter out requests exceeding this input sequence length
Yan Ru Pei's avatar
Yan Ru Pei committed
215

216
217
218
Examples:

```bash
219
220
# Use original trace dataset as-is (no synthesis parameters specified)
python real_data_benchmark.py --input-dataset trace.jsonl
221
222

# Speed up request rate by 2x and use only first 1000 requests
223
python real_data_benchmark.py --input-dataset trace.jsonl --num-requests 1000 --speedup-ratio 2.0
224
225

# Double prefix lengths to test cache efficiency with longer shared contexts
226
python real_data_benchmark.py --input-dataset trace.jsonl --prefix-len-multiplier 2.0
227
228

# Create more diverse workload by replicating prefix tree 3 times
229
python real_data_benchmark.py --input-dataset trace.jsonl --prefix-root-multiplier 3
230
```
Yan Ru Pei's avatar
Yan Ru Pei committed
231

232
233
234
235
236
237
238
> [!Note]
> At the time of writing this documentation, you may need to install the latest genai-perf from the main source branch to loadgen on the trace files:
> ```bash
> pip install git+https://github.com/triton-inference-server/perf_analyzer.git#subdirectory=genai-perf
> ```
> However, by the time of release, the genai-perf version included in the vLLM runtime container should be up to date enough to use as-is.

Yan Ru Pei's avatar
Yan Ru Pei committed
239
240
241
242
243
244
## Troubleshooting

1. **Workers fail to start**: Check CUDA_VISIBLE_DEVICES and GPU availability
2. **Router connection refused**: Ensure router is running and port is correct
3. **Benchmark timeout**: Decrease concurrency or reduce request count
4. **OOM errors**: Reduce max-num-batched-tokens or max-model-len in run_engines.sh