百度智能云函数计算 CFC 工作流并行（parallel）节点
文档简介：
parallel 节点用来并行执行多个节点，它定义了多个分支，每个分支内包含一系列串行的节点。
parallel 会把自己经过 stateDataFilter 过滤后的输入数据，拷贝给每个分支的开始节点，作为它们的输入数据。在所有分支执行结束后，parallel 再把分支的输出汇总，放入自己的节点数据内并输出。若其中一个分支执行失败，那么 parallel 节点也会失败。
咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！
微信咨询
免费试用、价格特惠
概述
parallel 节点用来并行执行多个节点，它定义了多个分支，每个分支内包含一系列串行的节点。
parallel 会把自己经过 stateDataFilter 过滤后的输入数据，拷贝给每个分支的开始节点，作为它们的输入数据。在所有分支执行结束后，parallel 再把分支的输出汇总，放入自己的节点数据内并输出。若其中一个分支执行失败，那么 parallel 节点也会失败。
参数
以下为 parallel 节点所包含的参数字段：
| 字段 | 类型 | 描述 |
|---|---|---|
| type（必需） | string | 节点类型，值为 "parallel" |
| name（必需） | string | 节点名称 |
| branches（必需） | array of branch | 分支数组 |
| next（二选一） | string | 当前节点运行结束后，下一个要运行的节点 |
| end（二选一） | bool | 设定 end 参数为 true，表示该节点运行结束后，没有继续要运行的节点。只可以定义 next 或 end中的一个 |
| description（可选） | string | 节点描述信息 |
| stateDataFilter（可选） | object | 节点输入输出过滤，参考输入与输出 |
| retry（可选） | object | 错误重试定义，参考错误重试 |
| catch（可选） | object | 错误捕获定义，参考错误捕获 |
分支 branch 的定义：
| 字段 | 类型 | 描述 |
|---|---|---|
| start（必需） | string | 分支的开始节点 |
| states（必需） | array of state | 该分支的节点数组 |
可以看到，分支的定义其实就是一个简化版的完整工作流的定义。
示例
示例工作流定义如下，parallel 节点定义了两个分支：
name: demo start: hello states: - type: parallel name: hello branches: -
start: func1 states: - type: operation name: func1 resource: "brn:bce:cfc:su:
123456:function:test1:$LATEST" next: func2 - type: operation name: func2 resource:
"brn:bce:cfc:su:123456:function:test2:$LATEST" end: true - start: pass1 states: -
type: pass name: pass1 data: bce: xflow end: true next: succ - type: succeed name: succ
假定工作流的输入是 {"hello":"world"}，那么 parallel 节点及两个分支的输入数据均为 {"hello":"world"}。
假定分支1的输出数据是 {"result":"success"}，分支2从定义可知输出数据是 {"hello":"world", "bce":"xflow"}，
最终 parallel 的输出数据是
{
"hello":"world",
"bce":"xflow",
"result":"success"
}
