Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

任务工作流状态

Task 状态 ("Type": "Task") 代表状态机执行的一个工作单元。任务通过使用活动或活动来执行工作 Amazon Lambda 函数，通过与其他支持的功能集成 Amazon Web Services 服务，或者通过调用第三方API，比如 Stripe。

Amazon States 语言通过将状态类型设置为Task并向任务提供活动的亚马逊资源名称 (ARN)、Lambda 函数或第三方API终端节点来表示任务。以下 Task 状态定义调用名为 HelloFunction 的 Lambda 函数。

"Lambda Invoke": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-2:123456789012:function:HelloFunction:$LATEST"
  },
  "End": true
}

任务类型

Step Functions 支持以下任务类型，您可以在 Task 状态定义中指定这些类型：

您可以通过在任务状态定义的Resource字段ARN中提供任务类型来指定任务类型。以下示例显示了 Resource 字段的语法。除调用第三方API的任务类型外，所有任务类型均使用以下语法。有关HTTP任务语法的信息，请参见在 Step Functions 工作流程APIs中致电第三方。

在任务状态定义中，将以下语法中的斜体文本替换为 Amazon 特定于资源的信息。

arn:partition:service:region:account:task_type:name

下面的列表解释了此语法中的各个组件：

以下各部分提供有关每种类型的更多详细信息。

活动

活动表示由您实现和托管的、用于执行某个特定任务的工作线程 (进程或线程)。它们只受标准工作流支持，而不受快速工作流支持。

活动ResourceARNs使用以下语法。

arn:partition:states:region:account:activity:name

有关创建活动和实现工作线程的更多信息，请参阅活动。

Lambda 函数

Lambda 任务使用以下命令执行函数 Amazon Lambda。 要指定 Lambda 函数，请使用字段中的 ARN Lambda 函数。Resource

取决于集成类型（优化集成或 Amazon SDK集成）用于指定 Lambda 函数，您的 Lambda 函数字段的语法会有所不同。Resource

以下 Resource 字段语法是 Lambda 函数的优化集成的示例。

"arn:aws:states:::lambda:invoke"

以下Resource字段语法是一个示例 Amazon SDK与 Lambda 函数集成。

"arn:aws:states:::aws-sdk:lambda:invoke"

以下 Task 状态定义显示了名为 HelloWorld 的 Lambda 函数的优化集成的示例。

"LambdaState": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "OutputPath": "$.Payload",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-1:function:HelloWorld:$LATEST"
  },
  "Next": "NextState"
}

在Resource字段中指定的 Lambda 函数完成后，其输出将发送到Next字段中标识的状态 (” NextState “)。

A 支持的 Amazon Web Services 服务

当您引用连接的资源时，Step Functions 会直接调用受支持服务的API操作。在 Resource 字段中指定服务和操作。

连接的服务ResourceARNs使用以下语法。

arn:partition:states:region:account:servicename:APIname

例如：

{
 "StartAt": "BATCH_JOB",
 "States": {
   "BATCH_JOB": {
     "Type": "Task",
     "Resource": "arn:aws:states:::batch:submitJob.sync",
     "Parameters": {  
       "JobDefinition": "preprocessing",
       "JobName": "PreprocessingBatchJob",
       "JobQueue": "SecondaryQueue",
       "Parameters.$": "$.batchjob.parameters",
       "RetryStrategy": {
          "attempts": 5
        }
     },
     "End": true
    }
  }
}

Task 状态字段

除了常见状态字段之外，Task 状态还具有以下字段。

Task 状态必须将 End 字段设置为 true（如果状态结束执行），或者必须在 Next 字段中提供一个状态（该状态将在 Task 状态完成时运行）。

Task 状态定义示例

以下示例说明如何根据要求指定 Task 状态定义。

Task 状态超时和检测信号间隔

为长时间运行的活动设置超时值和检测信号间隔是一个好的做法。这可以通过指定超时和检测信号值或通过动态设置来完成。

静态超时和检测信号通知示例

当 HelloWorld 完成后，将运行下一个状态（此处名为 NextState）。

如果此任务在 300 秒内未能完成，或者未在 60 秒的间隔内发送检测信号通知，则任务会被标记为 failed。

"ActivityState": {
  "Type": "Task",
  "Resource": "arn:aws:states:us-east-1:123456789012:activity:HelloWorld",
  "TimeoutSeconds": 300,
  "HeartbeatSeconds": 60,
  "Next": "NextState"
}

动态任务超时和检测信号通知示例

在这个例子中，当 Amazon Glue 作业完成，下一个状态将运行。

如果此任务未能在动态设置的时间间隔内完成 Amazon Glue job，则该任务被标记为failed。

"GlueJobTask": {
  "Type": "Task",
  "Resource": "arn:aws:states:::glue:startJobRun.sync",
  "Parameters": {
    "JobName": "myGlueJob"
  },
  "TimeoutSecondsPath": "$.params.maxTime",
  "Next": "NextState"
}