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

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

Task 工作流程状态

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

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

使用JSONata参数调用函数

以下任务状态定义 (JSONata) 调用名为的 Lambda 函数。priceWatcher

请注意使用JSONata表达式来查询要在 Arguments 中使用的输入数据，以及分配字段中的任务结果。

"Get Current Price": {
  "Type": "Task",
  "QueryLanguage" : "JSONata",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Next": "Check Price",
  "Arguments": {
    "Payload": {
    "product": "{% $states.context.Execution.Input.product %}"
    },
    "FunctionName": "arn:aws:lambda:<region>:123456789012:function:priceWatcher:$LATEST"
  },
  "Assign": {
    "currentPrice": "{% $states.result.Payload.current_price %}"
  }
}

使用JSONPath参数调用函数

以下任务状态定义 (JSONPath) 调用名为的 Lambda 函数。HelloFunction

"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 字段的语法。除调用的任务类型外，所有任务类型均HTTPSAPI使用以下语法。有关HTTP任务语法的信息，请参见调用 Step HTTPS APIs Functions 工作流程。

在任务状态定义中，将以下语法中的斜体文本替换为 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

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

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

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

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

"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 作业动态设置的时间间隔内完成，则该任务将被标记为 failed。

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