批处理节点
节点功能
批处理节点用于批量并行的执行任务,直到遍历完批处理数组的全部元素。批处理节点属于基础节点,支持配置输入变量、批处理并行上限、批处理数组和批处理体(工作流),并行执行特定的工作流。
说明:
批处理节点和循环节点的区别:循环节点串行处理数组元素,依次执行循环体工作流,并且支持对每次循环执行结果进行条件判断,以实现提前结束循环。批处理节点分批并行处理数组元素,不会提前结束批处理,适用于大量数据的并行处理场景,例如媒体文章的并行分析、数据预处理等。

操作说明
输入变量
输入变量仅在该节点内部生效,不能跨节点使用。支持最多添加50个输入变量,满足多输入变量场景需要。点击添加,进行如下配置添加输入变量。
配置 | 说明 |
变量名称 | 该变量的名称,只能包含字母、数字或下划线,并且以字母或下划线开头,必填。 |
数据来源 | 该变量的数据来源,支持"引用""输入"两种选项。"引用"可选择前序所有节点的输出变量,"输入"可手动填入固定值。 |
类型 | 该变量的数据类型,不可选择,默认为"引用"的变量类型或"输入"的 string 类型。 |
批处理设置
用于设置批处理执行过程,包括以下两项配置:
批处理并行上限:表示批处理任务的并行数量,用于控制同时执行多少个批处理体。支持设置范围为1~10次,当设置为1时即为串行执行,效果与循环节点的"遍历全部元素"效果相同。
批处理数组:表示用于执行批处理任务的数组,系统会依次提取批处理数组中的元素,按照批处理并行上限执行批处理体。
注意:
批处理数组只能选择数组类型的变量,例如:array<string>、array<int>、array<object> 等类型。
批处理体
表示执行批处理的工作流,支持选择"待发布"和"已发布"两种状态的工作流。选择好工作流后,页面会自动展示该工作流的输入变量,并支持用户设置这些变量的数据来源。
批处理体输入变量
批处理体输入变量即所选择的批处理工作流的输入变量,支持引用批处理节点的输入变量以及批处理数组的元素(通过item字段引入,例如批处理数组为arrObj,则通过 arrObj.Item 引用该数组中的元素)。

输出变量
经该节点处理后的输出变量。包含批处理体运行后汇总的结果 Results(数据类型为array<object>),以及运行时报错信息Error(数据类型为 object,正常运行时该字段为空)。不支持用户手动新增。

智能体应用示例
批量分析社媒文章,输出文章的标签及正负面情绪。

其中批处理节点配置如下:

常见问题
如果批处理数组元素数量大于批处理并行上限,如何处理?
此时系统会根据批处理并行上限依次运行批处理数组中的元素,其他元素将通过排队机制等待运行。
