循环状态及其相关使用示例_云工作流(CloudFlow)-阿里云帮助中心

本文介绍循环状态及其相关使用示例。

基本概念

循环状态遍历输入中的某个数组类型参数，对于数组中的每个元素，并行执行其处理器（Processor）状态。循环状态类似于编程语言中的foreach，不同之处是这里的迭代是并行执行的。

执行并行循环步骤会并发执行输入参数中的每个元素的处理器状态。当所有分支执行结束后，默认将输出一个包含所有分支结果的map[string]any，然后通过输出构造器将结果进行进一步处理。

说明

循环状态最大并发数限制为 100，具体能够支持的并发，与实际业务的IO Size有很大的关系。

循环状态包含以下属性。

字段	类型	是否必选	描述	示例值
Name	string	是	状态名称。	my-state-name
Description	string	否	状态描述。	“describe it here”
Type	string	是	状态类型。	Map
InputConstructor	map[string]any	否	输入构造器。	请参见输入构造器
ItemsPath	string	是	用于提取输入数组的表达式。	请参见ItemsPath
Processor	ItemProcessor	是	迭代处理器。	请参见ItemProcessor
OutputConstructor	map[string]any	否	输出构造器。	请参见输出构造器
Next	string	否	当前状态的下一状态。当End取值为true时，无需指定。	my-next-state
End	bool	否	是否为当前作用域的终结节点。	true

ItemsPath

该表达式执行后返回JSON Array，则可以进行迭代，将其中每个元素传入ItemProcessor进行处理；可使用表达式变量$Context和$Input，示例如下。

$Input.FieldA

ItemProcessor

字段	类型	是否可选	描述	示例值
States	array	是	内部嵌套的状态数组。	详见示例
StartAt	string	是	内部嵌套状态数组的执行起点。	my start task

使用示例

以下示例流程定义一个循环状态，这个循环步骤处理器包含一个通过状态。

Type: StateMachine
Name: my-wkfl
SpecVersion: v1
StartAt: Map1
States:
  - Type: Map
    Name: Map1
    End: true
    InputConstructor:
      FieldA: 
        - a : b
        - c : d
        - e : f
    ItemsPath: $Input.FieldA
    Processor:
      StartAt: Pass1
      States:
        - Type: Pass
          Name: Pass1
          End: true

流程的输入构造结果如下所示。

{
	"FieldA": [
  	{
			"a": "b"
		},
    {
			"c": "d"
		},
    {
			"e": "f"
		}
  ]
}

针对Map，系统会对所有迭代Processor的输出结果进行合并，默认以关键字 "Items" 作为Key，合并后的结果作为Value；Map1的输出结果如下所示，自动添加此输出也是最后流程执行的输出。

{
	"Items": [
  	{
			"a": "b"
		},
    {
			"c": "d"
		},
    {
			"e": "f"
		}
  ]
}