跳至主要內容

Express adapter

@mastra/express 套件提供 server adapter,讓 Mastra 可配合 Express 運行。有關一般 adapter 概念(constructor 選項、初始化流程等),請參閱 Server adapter

安裝
安裝 的直接連結

安裝 Express adapter 及 Express framework:

npm install @mastra/express@latest express

使用範例
使用範例 的直接連結

server.ts
import express from 'express'
import { MastraServer } from '@mastra/express'
import { mastra } from './mastra'

const app = express()
app.use(express.json()) // Required for body parsing

const server = new MastraServer({ app, mastra })
await server.init()

app.listen(4111, () => {
console.log('Server running on port 4111')
})
備註

Express 需要 express.json() middleware 才能解析 JSON body。請在建立 MastraServer 前加入。

Constructor 參數
Constructor 參數 的直接連結

app:

Application
Express app instance

mastra:

Mastra
Mastra instance

prefix?:

string
= ''
Route 路徑前綴(例如 /api/v2

openapiPath?:

string
= ''
提供 OpenAPI 規格的路徑(例如 /openapi.json

bodyLimitOptions?:

{ maxSize: number, onError: (err) => unknown }
Request body 大小限制

streamOptions?:

{ redact?: boolean }
= { redact: true }
Stream 遮蔽設定。設為 true 時,會從 stream 遮蔽敏感資料。

customRouteAuthConfig?:

Map<string, boolean>
各 route 的 auth 覆寫設定。Key 為 METHOD:PATH(例如 GET:/api/health)。值為 false 時 route 會公開,true 則需要 auth。

tools?:

Record<string, Tool>
Server 可用的 Tool

taskStore?:

InMemoryTaskStore
A2A(Agent-to-Agent)操作的 task store

mcpOptions?:

MCPOptions
MCP transport 選項。對 Cloudflare Workers 或 Vercel Edge 等無狀態環境,請設定 serverless: true

與 Hono 的分別
與 Hono 的分別 的直接連結

項目ExpressHono
Body 解析需要 express.json()由 framework 處理
Context 儲存res.localsc.get() / c.set()
Middleware signature(req, res, next)(c, next)
Streamingres.write() / res.end()stream() helper
AbortSignalreq.on('close') 建立c.req.raw.signal

新增自訂 route
新增自訂 route 的直接連結

直接將 route 新增至 Express app:

server.ts
const app = express()
app.use(express.json())

const server = new MastraServer({ app, mastra })

// Before init - runs before Mastra middleware
app.get('/early-health', (req, res) => res.json({ status: 'ok' }))

await server.init()

// After init - has access to Mastra context
app.get('/custom', (req, res) => {
const mastraInstance = res.locals.mastra
res.json({ agents: Object.keys(mastraInstance.listAgents()) })
})

app.listen(4111)
提示

init() 前新增的 route 會在沒有 Mastra context 的情況下運行。如要存取 Mastra instance 及 request context,請在 init() 後新增 route。

如需 Mastra 管理的 auth,以及 requiresAuth 等 route metadata,建議使用 registerApiRoute()。對於直接掛載到 app 的原始 Express route,請使用 createAuthMiddleware()

server.ts
import express from 'express'
import { createAuthMiddleware, MastraServer } from '@mastra/express'
import { mastra } from './mastra'

const app = express()
app.use(express.json())

const server = new MastraServer({ app, mastra })
await server.init()

app.get('/custom/protected', createAuthMiddleware({ mastra }), (req, res) => {
const user = res.locals.requestContext.get('user')
res.json({ user })
})

app.get('/custom/public', createAuthMiddleware({ mastra, requiresAuth: false }), (req, res) => {
res.json({ ok: true })
})

存取 context
存取 context 的直接連結

在 Express middleware 及 route 中,透過 res.locals 存取 Mastra context:

app.get('/custom', (req, res) => {
const mastra = res.locals.mastra
const requestContext = res.locals.requestContext
const abortSignal = res.locals.abortSignal

const agent = mastra.getAgent('myAgent')
res.json({ agent: agent.name })
})

res.locals 的可用 property:

Key說明
mastraMastra instance
requestContextRequest context map
abortSignalRequest 取消訊號
tools可用的 Tool
taskStoreA2A 操作的 task store
customRouteAuthConfig各 route 的 auth 覆寫設定
user已驗證的使用者(如已設定 auth)

新增 middleware
新增 middleware 的直接連結

init() 前或後新增 Express middleware:

server.ts
const app = express()
app.use(express.json())

// Middleware before init
app.use((req, res, next) => {
console.log(`${req.method} ${req.url}`)
next()
})

const server = new MastraServer({ app, mastra })
await server.init()

// Middleware after init has access to Mastra context
app.use((req, res, next) => {
const mastra = res.locals.mastra
next()
})

手動初始化
手動初始化 的直接連結

如要自訂 middleware 順序,請分別呼叫各個 method,而非使用 init()。詳情請參閱手動初始化

範例
範例 的直接連結