Agent 创收指南免费公开资源
中文 EN العربية

返回目录 / Agent 工作流

并行处理独立文档或查询并限制并发数

对列表中的独立项目运行同一Agent节点,同时限制并发量并保持输出顺序。

目标

缩短I/O密集批任务的总等待时间,同时避免突发请求压垮下游服务。

步骤

  1. 确认每个列表元素可以独立处理,不依赖其他元素写入的状态。 [parallel]
  2. 将单项逻辑包装成 @node(parallel_worker=True, max_parallel_workers=4),worker参数接收单个 node_input。 [parallel]
  3. 设置保守的最大并发数,并确认输入参数名符合节点接口约定。 [parallel]
  4. 检查输出与输入顺序对应,并测试一项失败时剩余任务的取消和错误传播。 [parallel]

验证方式

结果数量和顺序与输入一致,并发不超过配置值;失败时按预期取消或报告。

故障处理

若节点报缺少输入,检查节点输入参数名称;若下游限流,降低并发上限并加总时限。

权限边界

前置条件

权限边界

限制

内容依据固定提交中的Google ADK实现;不同版本、模型或远端服务可能有不同接口与事件语义。上线前验证权限、数据保留和失败恢复。

固定上游来源

https://github.com/google/adk-python/blob/e9b74d36140f2594b24c481fb7a3825b2cb01e96/docs/guides/workflow/parallel_worker/index.md

仓库
google/adk-python
文件路径
docs/guides/workflow/parallel_worker/index.md
固定提交
e9b74d36140f2594b24c481fb7a3825b2cb01e96
来源检查
2026-10-14 · 已按固定上游来源核对

仓库指标

以下数字属于上游仓库整体,不代表单个 Skill 或指南的点赞/热度。

Stars
未取得
Forks
未取得
观测时间
未取得

尚未取得指标快照。

许可证: Apache-2.0

主主题

把电商活动资料整理成可复核周报

相关资源