Nexent Doc

简体中文

English

简体中文

English

Appearance

AI 智能体开发概览 ​

Nexent 提供全面的 AI 智能体开发和部署框架，具备高级功能，包括工具集成、推理和多模态交互。

🏗️ 智能体架构 ​

核心组件 ​

NexentAgent - 企业级智能体框架 ​

Nexent 智能体系统的核心，提供完整的智能体解决方案：

  • 多模型支持: 支持 OpenAI、视觉语言模型、长上下文模型等
  • MCP 集成: 无缝集成 Model Context Protocol 工具生态
  • 动态工具加载: 支持本地工具和 MCP 工具的动态创建和管理
  • 分布式执行: 基于线程池和异步架构的高性能执行引擎
  • 状态管理: 完善的任务状态追踪和错误恢复机制

CoreAgent - 代码执行引擎 ​

继承并增强了 SmolAgents 的 CodeAgent，提供以下关键能力：

  • Python代码执行: 支持解析和执行Python代码，能够动态处理任务
  • 多语言支持: 内置中英文提示词模板，可根据需要切换语言
  • 流式输出: 通过 MessageObserver 实现模型输出的实时流式显示
  • 步骤追踪: 记录并展示Agent执行的每个步骤，便于调试和监控
  • 中断控制: 支持任务中断和优雅停止机制
  • 错误处理: 完善的错误处理机制，提高稳定性
  • 状态管理: 维护和传递执行状态，支持复杂任务的连续处理

CoreAgent 实现了ReAct框架的思考-行动-观察循环：

  1. 思考: 使用大语言模型生成解决方案代码
  2. 行动: 执行生成的Python代码
  3. 观察: 收集执行结果和日志
  4. 重复: 根据观察结果继续思考和执行，直到任务完成

📡 MessageObserver - 流式消息处理 ​

消息观察者模式的核心实现，用于处理 Agent 的流式输出：

  • 流式输出捕获: 实时捕获模型生成的token
  • 过程类型区分: 根据不同的处理阶段（模型输出、代码解析、执行日志等）格式化输出
  • 多语言支持: 支持中英文输出格式
  • 统一接口: 为不同来源的消息提供统一处理方式

ProcessType枚举定义了以下处理阶段：

  • STEP_COUNT: 当前执行步骤
  • MODEL_OUTPUT_THINKING: 模型思考过程输出
  • MODEL_OUTPUT_CODE: 模型代码生成输出
  • PARSE: 代码解析结果
  • EXECUTION_LOGS: 代码执行结果
  • AGENT_NEW_RUN: Agent基本信息
  • FINAL_ANSWER: 最终总结结果
  • SEARCH_CONTENT: 搜索结果内容
  • PICTURE_WEB: 网络图片处理结果

🤖 智能体开发 ​

创建基本智能体 ​

python
from nexent.core import MessageObserver, ProcessType
from nexent.core.agents import CoreAgent, NexentAgent
from nexent.core.models import OpenAIModel
from nexent.core.tools import ExaSearchTool, KnowledgeBaseSearchTool

# 创建消息观察者
observer = MessageObserver()

# 创建模型（model和Agent必须使用同一个observer）
model = OpenAIModel(
    observer=observer,
    model_id="your-model-id",
    api_key="your-api-key",
    api_base="your-api-base"
)

# 创建工具
search_tool = ExaSearchTool(exa_api_key="your-exa-key", observer=observer, max_results=5)
kb_tool = KnowledgeBaseSearchTool(top_k=5, observer=observer)

# 创建Agent
agent = CoreAgent(
    observer=observer,
    tools=[search_tool, kb_tool],
    model=model,
    name="my_agent",
    max_steps=5
)

# 运行Agent
result = agent.run("你的问题")

自定义智能体开发 ​

系统提示词模板 ​

系统提示词模板位于 backend/prompts/：

  • knowledge_summary_agent.yaml: 知识库摘要代理
  • manager_system_prompt_template.yaml: 管理器系统提示词模板
  • utils/: 提示词工具

智能体实现步骤 ​

  1. 创建智能体实例:

    python
    from nexent.core.agents import CoreAgent
from nexent.core.models import OpenAIModel

model = OpenAIModel(
    model_id="your-model-id",
    api_key="your-api-key",
    api_base="your-api-base"
)
agent = CoreAgent(
    model=model,
    tools=[your_tools],
    system_prompt="你的系统提示词"
)

  2. 配置智能体行为:

    • 通过 tools 参数添加自定义工具
    • 通过 system_prompt 设置行为
    • 配置 max_steps、temperature 等参数

  3. 高级配置:

    python
    agent = CoreAgent(
    model=model,
    tools=custom_tools,
    system_prompt=custom_prompt,
    max_steps=10,
    temperature=0.7,
    verbose=True,
    additional_authorized_imports=["requests", "pandas"]
)

🛠️ 工具集成 ​

自定义工具开发 ​

Nexent 基于 Model Context Protocol (MCP) 实现工具系统。

开发新工具: ​

  1. 在 backend/mcp_service/local_mcp_service.py 实现逻辑
  2. 用 @mcp.tool() 装饰器注册
  3. 重启 MCP 服务

示例: ​

python
@mcp.tool(name="my_tool", description="我的自定义工具")
def my_tool(param1: str, param2: int) -> str:
    # 实现工具逻辑
    return f"处理结果: {param1} {param2}"

工具开发规范 ​

详细的工具开发规范和最佳实践，请参阅：

🎯 智能体执行模式 ​

ReAct 模式 ​

问题解决智能体的标准执行模式：

  1. 推理: 分析问题并制定方法
  2. 行动: 执行工具或生成代码
  3. 观察: 检查结果和输出
  4. 迭代: 继续直到任务完成

多智能体协作 ​

  • 分层智能体: 管理智能体协调工作智能体
  • 专业智能体: 特定任务的领域专用智能体
  • 通信协议: 智能体间的标准化消息传递

错误处理和恢复 ​

  • 优雅降级: 工具失败时的备选策略
  • 状态持久化: 保存智能体状态以便恢复
  • 重试机制: 带退避策略的自动重试

⚡ 性能优化 ​

执行效率 ​

  • 并行工具执行: 独立工具的并发运行
  • 缓存策略: 缓存模型响应和工具结果
  • 资源管理: 高效的内存和计算使用

监控和调试 ​

  • 执行跟踪: 智能体决策的详细日志
  • 性能指标: 时间和资源使用追踪
  • 调试模式: 开发时的详细输出

📋 最佳实践 ​

智能体设计 ​

  1. 明确目标: 定义具体、可测量的智能体目标
  2. 适当工具: 选择与智能体能力匹配的工具
  3. 强大提示词: 创建全面的系统提示词
  4. 错误处理: 实现全面的错误恢复

开发工作流 ​

  1. 迭代开发: 增量构建和测试
  2. 提示词工程: 基于测试结果优化提示词
  3. 工具测试: 集成前验证单个工具
  4. 性能测试: 监控和优化执行速度

生产部署 ​

  1. 资源分配: 确保充足的计算资源
  2. 监控设置: 实现全面的日志和告警
  3. 扩展策略: 规划增加的负载和使用
  4. 安全考虑: 验证输入并保护API访问

详细的实现示例和高级模式，请参阅 开发指南。