数据传递

基本概念

云工作流的状态（State）之间可以进行组合嵌套，单个状态（State）运行过程中，其所处的环境中一些数据称为上下文。数据分类如下：

• 流程数据：流程（Flow）的名称、地域；组成流程的各个状态（State）名称；流程执行过程中依赖的访问角色等信息；

• 执行数据：执行（Execution）的名称、执行输入；执行过程中当前状态（State）的输入、输出；执行中生成的用于回调的Token信息，以及执行过程中状态（State）发生错误之后，产生的错误信息，针对错误处理的重试次数等信息。

数据访问

与流程和流程执行相关的数据，无论是静态数据，还是动态数据，您都通过系统提供的$Context表达式来访问相关的数据，Context中包含的数据内容如下：

{
  "Execution": {
    "Name": "String",
    "Input": {},
    "RoleArn": "String"
  },
  "Current": {
    "Name": "String",
    "Input": {},
    "Output": {},
    "Error": {
      "Code": "String",
      "Detail": "String"
    },
    "RetryCount": "Number",
    "TaskToken": "String"
  }
}

Context 可用于下面场景的数据构造：

• 输入输出构造器。详细信息，请参见输入和输出和状态输出构造器。

• 循环状态中的ItemsPath字段，例如$Context.Current.Input。

• 选择状态中的Condition字段，例如$Context.Current.Input.Size>=1024。

• 错误处理信息判断，例如$Context.Current.Error.Code或 $Context.Current.Error.Detail。

• 任务回调Token 传递，例如$Context.Current.TaskToken。

为了方便用户使用，云工作流提供两个使用频率较高的快捷方式$Input $Output，您可以使用其快速访问当前节点的输入和输出。

• $Input 等价于 $Context.Current.Input

• $Output 等价于 $Context.Current.Output

数据传递

不同类型的状态（State）之间存在不同的输入输出传输逻辑，在没有输入输出构造器定义的情况下，不同状态（State）的输入输出逻辑如下。

• 传递（Pass）/成功（Succeed）/失败（Fail）/等待（Wait）状态：接受输入，不做任何处理，直接输出。

• 选择（Choice）状态：只具备输入能力，会将自身的输入传递到指向的状态。例如，平移传输到Default，或者到某分支判断条件是否成立，如果条件成立，则将输入传输到Next状态。

• 并行（Parallel）状态：同一份输入，将会被深拷贝后同时传输给多个分支。输出将会被收集为Map[String]Any的形式，其中Key是每个Parallel分支的隐式名称 “Branch0～BranchN”，对应Value是每个Parallel分支实际的处理结果。

• 循环（Map）状态：同一份输入，将会判断是否为数组或者Map[String]Any，特别强调的是，当Map的输入不是数组时，如果用户也没有通过ItemsPath设置指定要迭代的内容，系统会自动获取Map的Values作为迭代数组；系统将会对该数组进行迭代，每一个数组元素将会作为迭代处理器的输入；Map输出将会被收集为Map[String]Array的形式，其中Key是固定字符串“Items”，Value是由多个迭代结果组成的数组。

使用示例

Type: StateMachine
Name: DataTransferExample
SpecVersion: v1
StartAt: Step1
States:
  - Type: Pass
    Name: Step1
    Next: Step2
  - Type: Parallel
    Name: Step2
    InputConstructor:
      FieldA: 123
    Branches:
      - StartAt: Pass1
        States:
          - Type: Pass
            Name: Pass1
            End: true
      - StartAt: Pass2
        States:
          - Type: Pass
            Name: Pass2
            End: true
    Next: Step3
  - Type: Pass
    Name: Step3
    End: true

以上示例中，在 Parallel 类型的 Step2 状态中使用输入构造器，构造了包含一个属性的 JSONObject，其中属性FieldA为123。 该输入被默认传输给ParallelBranch #0与ParallelBranch #1。以其中一个Branch为例，在ParallelBranch #0中，输入被传输给Pass1，站在Pass1运行完成的角度，上下文数据如下所示。

{
  "Execution": {
    "Name": "xxxx-xxxx-xxxx-xxxx",
    "Input": {},
    "RoleArn": "xxxx"
  },
  "Current": {
    "Name": "Pass1",
    "Input": {
      "FieldA": 123
    },
    "Output": {
      "FieldA": 123
    },
    "Error": null,
    "RetryCount": 0
  }
}