@xx/ai-stream

xx AI 能力

概述

包含了 xx AI 系统的新一代流式处理架构，支持：

• Agent 系统架构 - 基于工厂模式的类型安全 Agent 系统
• LangGraph 集成 - 基于 langgraph.js v1.0, 支持完整的 LangChain 生态系统
• 流式数据处理 - 实时数据流和事件驱动架构
• Thought Tracking - 内置的执行过程追踪和调试系统
• 多种 AI 模型支持 - 支持 OpenAI、Anthropic 等多种 LLM

安装

pnpm add @xx/ai-stream

快速开始

import { askxxStream } from '@xx/ai-stream'

// 创建 AI 流式处理
const stream = askxxStream({
  messages: [userMessage],
  context: {
    agentType: 'xxx',
  }
  environment: { env: 'production' },
  llmConfig: { model: 'gpt-4', apiKey: 'your-api-key' },
})

// 处理流式事件
for await (const event of stream) {
  console.log('Event:', event)
}

文档

• 快速开始 - 5 分钟上手指南
• Domain Agent 开发指南 - 完整的 Agent 开发 SOP
• Graph 动态架构 - 动态 Agent 注册和路由机制
• 多 Agent 架构演进说明 - 优化前后架构差异和 Harness 化建议
• Monorepo Chat 应用技术方案 - NestJS 后端、Ant Design X 前端和 Agent Runtime 整合方案
• 阶段 1/2 完成产物和自测计划 - 阶段验收产物、测试用例和烟测流程
• 架构说明 - 系统整体架构设计
• API 参考 - 核心 API 导出
• 测试示例 - 单元测试和集成测试示例

架构特性

🏗️ 动态 Agent 注册

• 完全动态：Graph 根据 AgentRegistry 自动创建节点和边
• 类型安全：Agent 创建和管理全程类型检查
• 标准化接口：统一的 Agent 生命周期和执行模式
• 易于扩展：只需注册新 Agent，无需修改 Graph 代码

🔄 事件驱动架构

• 基于 emit 的消息传递
• 完整的流式事件系统
• 实时进度追踪和调试

🧠 Thought Tracking

• 执行过程可视化
• 性能监控和调试
• 错误追踪和诊断

📦 附件系统

• 统一的附件抽象
• 类型安全的附件创建
• 支持 Schema、Template、Answer 等多种类型

🔀 智能路由

• Controller Agent 自动分析用户意图
• 条件路由到对应的 Domain Agent
• 支持降级和错误恢复

现有 Agent

• ControllerAgent - 根据消息列表和业务上下文，识别用户意图，分发任务，路由到指定领域智能体并生成目标智能体所需要的入参
• 剩余的后续实现，初始化架构可忽略

开发

# 安装依赖
pnpm install

# 启动开发模式
pnpm start

# 构建
pnpm build

# 运行本地测试
pnpm test:local

贡献

在开发新的 Domain Agent 之前，请阅读 Domain Agent 开发指南。

许可证

MIT