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

 

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

 

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

 

异常处理
可手动开启异常处理,支持异常重试和异常情况的输出内容配置。配置内容如下:
配置  | 说明  | 
最大重试次数  | 节点运行异常时重新运行的最大次数。重试超过设定次数,认为该节点调用失败,返回“异常情况的输出变量”内容,默认为3次  | 
重试时间间隔  | 每次重新运行的时间间隔,默认为1秒  | 
异常处理方式  | 支持“输出特定内容”和“执行异常流程”两种  | 
异常情况的输出变量  | 选择异常处理方式为“输出特定内容”时,超过最大重试次数后节点返回的输出变量  | 

 

选择异常处理方式为“执行异常流程”时,则节点异常重试后执行用户自定义的异常处理流程。

 

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

 

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

 

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