💡 摘要
Cloudflare Agents SDK 使创建具有调度和消息持久性等功能的有状态 AI 代理成为可能。
🎯 适合人群
🤖 AI 吐槽: “该 SDK 可能会暴露 RPC 方法,如果未正确保护,可能导致未经授权的访问。实施身份验证和授权检查以降低风险。”
该 SDK 可能会暴露 RPC 方法,如果未正确保护,可能导致未经授权的访问。实施身份验证和授权检查以降低风险。
name: agents-sdk description: Build stateful AI agents using the Cloudflare Agents SDK. Load when creating agents with persistent state, scheduling, RPC, MCP servers, email handling, or streaming chat. Covers Agent class, AIChatAgent, state management, and Code Mode for reduced token usage.
Cloudflare Agents SDK
Build persistent, stateful AI agents on Cloudflare Workers using the agents npm package.
FIRST: Verify Installation
npm install agents
Agents require a binding in wrangler.jsonc:
{ "durable_objects": { // "class_name" must match your Agent class name exactly "bindings": [{ "name": "Counter", "class_name": "Counter" }] }, "migrations": [ // Required: list all Agent classes for SQLite storage { "tag": "v1", "new_sqlite_classes": ["Counter"] } ] }
Choosing an Agent Type
| Use Case | Base Class | Package |
|----------|------------|---------|
| Custom state + RPC, no chat | Agent | agents |
| Chat with message persistence | AIChatAgent | @cloudflare/ai-chat |
| Building an MCP server | McpAgent | agents/mcp |
Key Concepts
- Agent base class provides state, scheduling, RPC, MCP, and email capabilities
- AIChatAgent adds streaming chat with automatic message persistence and resumable streams
- Code Mode generates executable code instead of tool calls—reduces token usage significantly
- this.state / this.setState() - automatic persistence to SQLite, broadcasts to clients
- this.schedule() - schedule tasks at Date, delay (seconds), or cron expression
- @callable decorator - expose methods to clients via WebSocket RPC
Quick Reference
| Task | API |
|------|-----|
| Persist state | this.setState({ count: 1 }) |
| Read state | this.state.count |
| Schedule task | this.schedule(60, "taskMethod", payload) |
| Schedule cron | this.schedule("0 * * * *", "hourlyTask") |
| Cancel schedule | this.cancelSchedule(id) |
| Queue task | this.queue("processItem", payload) |
| SQL query | this.sql`SELECT * FROM users WHERE id = ${id}` |
| RPC method | @callable() async myMethod() { ... } |
| Streaming RPC | @callable({ streaming: true }) async stream(res) { ... } |
Minimal Agent
import { Agent, routeAgentRequest, callable } from "agents"; type State = { count: number }; export class Counter extends Agent<Env, State> { initialState = { count: 0 }; @callable() increment() { this.setState({ count: this.state.count + 1 }); return this.state.count; } } export default { fetch: (req, env) => routeAgentRequest(req, env) ?? new Response("Not found", { status: 404 }) };
Streaming Chat Agent
Use AIChatAgent for chat with automatic message persistence and resumable streaming.
Install additional dependencies first:
npm install @cloudflare/ai-chat ai @ai-sdk/openai
Add wrangler.jsonc config (same pattern as base Agent):
{ "durable_objects": { "bindings": [{ "name": "Chat", "class_name": "Chat" }] }, "migrations": [{ "tag": "v1", "new_sqlite_classes": ["Chat"] }] }
import { AIChatAgent } from "@cloudflare/ai-chat"; import { routeAgentRequest } from "agents"; import { streamText, convertToModelMessages } from "ai"; import { openai } from "@ai-sdk/openai"; export class Chat extends AIChatAgent<Env> { async onChatMessage(onFinish) { const result = streamText({ model: openai("gpt-4o"), messages: await convertToModelMessages(this.messages), onFinish }); return result.toUIMessageStreamResponse(); } } export default { fetch: (req, env) => routeAgentRequest(req, env) ?? new Response("Not found", { status: 404 }) };
Client (React):
import { useAgent } from "agents/react"; import { useAgentChat } from "@cloudflare/ai-chat/react"; const agent = useAgent({ agent: "Chat", name: "my-chat" }); const { messages, input, handleSubmit } = useAgentChat({ agent });
Detailed References
- references/state-scheduling.md - State persistence, scheduling, queues
- references/streaming-chat.md - AIChatAgent, resumable streams, UI patterns
- references/codemode.md - Generate code instead of tool calls (token savings)
- references/mcp.md - MCP server integration
- references/email.md - Email routing and handling
When to Use Code Mode
Code Mode generates executable JavaScript instead of making individual tool calls. Use it when:
- Chaining multiple tool calls in sequence
- Complex conditional logic across tools
- MCP server orchestration (multiple servers)
- Token budget is constrained
See references/codemode.md for setup and examples.
Best Practices
- Prefer streaming: Use
streamTextandtoUIMessageStreamResponse()for chat - Use AIChatAgent for chat: Handles message persistence and resumable streams automatically
- Type your state:
Agent<Env, State>ensures type safety forthis.state - Use @callable for RPC: Cleaner than manual WebSocket message handling
- Code Mode for complex workflows: Reduces round-trips and token usage
- Schedule vs Queue: Use
schedule()for time-based,queue()for sequential processing
优点
- 支持有状态的 AI 代理
- 与 Cloudflare Workers 集成良好
- 提供调度和 RPC 功能
- 促进聊天中的消息持久性
缺点
- 需要理解 Cloudflare Workers
- 复杂性可能会让初学者感到不知所措
- 聊天需要依赖外部包
- 高级用例的示例有限
相关技能
免责声明:本内容来源于 GitHub 开源项目,仅供展示和评分分析使用。
版权归原作者所有 cloudflare.
