返回目录 / Agent 工作流
并行处理独立文档或查询并限制并发数
对列表中的独立项目运行同一Agent节点,同时限制并发量并保持输出顺序。
目标
缩短I/O密集批任务的总等待时间,同时避免突发请求压垮下游服务。
步骤
- 确认每个列表元素可以独立处理,不依赖其他元素写入的状态。 [parallel]
- 将单项逻辑包装成
@node(parallel_worker=True, max_parallel_workers=4),worker参数接收单个node_input。 [parallel] - 设置保守的最大并发数,并确认输入参数名符合节点接口约定。 [parallel]
- 检查输出与输入顺序对应,并测试一项失败时剩余任务的取消和错误传播。 [parallel]
验证方式
结果数量和顺序与输入一致,并发不超过配置值;失败时按预期取消或报告。
故障处理
若节点报缺少输入,检查节点输入参数名称;若下游限流,降低并发上限并加总时限。
权限边界
前置条件
- Python 3.11+、与固定提交兼容的 google-adk 安装、隔离测试环境
- 已配置的模型提供商凭据(真实推理需要;不要写入代码或日志)
权限边界
- 仅访问获准的测试数据;按用户范围隔离session与凭证;任何外部副作用先经人工授权
限制
内容依据固定提交中的Google ADK实现;不同版本、模型或远端服务可能有不同接口与事件语义。上线前验证权限、数据保留和失败恢复。
固定上游来源
- 仓库
- google/adk-python
- 文件路径
- docs/guides/workflow/parallel_worker/index.md
- 固定提交
e9b74d36140f2594b24c481fb7a3825b2cb01e96- 来源检查
- 2026-10-14 · 已按固定上游来源核对
仓库指标
以下数字属于上游仓库整体,不代表单个 Skill 或指南的点赞/热度。
- Stars
- 未取得
- Forks
- 未取得
- 观测时间
- 未取得
尚未取得指标快照。
许可证: Apache-2.0