Parallel-Stream-Node 模块
模块说明
在利用Graph搭建工作流时,我们希望能对节点并行处理加快执行效率,同时希望每个节点在对AI模型调用时能实时输出结果。
接口文档
GraphStreamController 接口
1. expand 方法
接口路径: GET /graph/parallel-stream/expand-translate
功能描述: 提供 expand 相关功能
主要特性:
- 基于 Spring Boot REST API 实现
- 返回 JSON 格式响应
- 支持 UTF-8 编码
使用场景:
- 数据处理和响应
- API 集成测试
示例请求:
GET http://localhost:8080/graph/parallel-stream/expand-translate
技术实现
核心组件
- Spring Boot: 应用框架
- Spring AI Alibaba: AI 功能集成
- REST Controller: HTTP 接口处理
- spring-ai-alibaba-starter-dashscope: 核心依赖
- spring-ai-autoconfigure-model-chat-client: 核心依赖
- spring-ai-alibaba-graph-core: 核心依赖
- spring-boot-starter-web: 核心依赖
配置要点
- 需要配置
AI_DASHSCOPE_API_KEY环境变量 - 默认端口:8080
- 默认上下文路径:/basic
测试指导
使用 HTTP 文件测试
模块根目录下提供了 parallel-stream-node.http 文件,包含所有接口的测试用例:
- 可在 IDE 中直接执行
- 支持参数自定义
- 提供默认示例参数
使用 curl 测试
# expand 接口测试
curl "http://localhost:8080/graph/parallel-stream/expand-translate"
注意事项
- 环境变量: 确保
AI_DASHSCOPE_API_KEY已正确设置 - 网络连接: 需要能够访问阿里云 DashScope 服务
- 字符编码: 所有响应使用 UTF-8 编码,支持中文内容
- 端口配置: 确保端口 8080 未被占用
此 README.md 由自动化工具生成于 2025-12-11 00:41:58