文档首页/ 应用与数据集成平台 ROMA Connect/ 用户指南（新版）/ 处理器/ 并行处理
更新时间：2025-05-08 GMT+08:00
查看PDF
分享

并行处理

“并行处理”是用于创建多个并行处理分支的处理器，以便同时执行多个分支任务。后续步骤如果要使用合并的各分支执行结果，可使用“ROMA表达式”${body}引用合并结果。

配置参数

参数

说明

输出格式

合并结果的格式，当前仅支持“Json”，表示合并结果以JSON字符串的格式输出。

可通过如下两种方法获取某一分支的结果：

  • 后续节点为“脚本处理”时，使用JSON.parse('${body}')方式将合并结果转换为JSON对象，然后通过分支名称获取分支的结果。如：

    var result=JSON.parse('${body}');

    var branch_result=result.分支名称

    或者

    var branch_result=result['分支名称']

  • 后续节点为“变量赋值”、“分支判断”和“数据转换”时，使用“$.分支名”获取该分支的执行结果。

失败时停止

并行处理一个分支出现错误时是否整体终止流运行。

  • True：表示任一并行处理的分支出现错误时，整个任务便停止，并返回错误信息。
  • False：表示并行处理的分支出现错误后，整个任务会继续执行后续节点。

超时时间(ms)

请输入0-60000之间的整数，0代表不设置超时时间，超时时间指定了整个并行处理的时间上限，如果设置了超时时间，一旦并行任务的执行时间超过该上限，并行处理就会失败。

“并行处理”节点的分支名称，需在后续相邻节点的连线上配置。

输出变量：

参数

说明

Aggregation complete time

各分支执行完成后，完成聚合结果的UTC时间，如2023-03-01T10:26:33.410Z。

Aggregation payload

并行处理的各分支执行完成后的聚合结果。

Start time

节点执行开始时间。

End time

节点执行结束时间。

Execution time

节点执行耗时，单位：ms。

输出变量Aggregation payload的数据格式：

{
    "branch_1": {
        "result_1": "api 1 success"
    },
    "branch_2": {
        "result_2": "api 2 success"
    }
}
父主题： 处理器