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

任务工作流状态

Task 状态 ("Type": "Task") 代表状态机执行的一个工作单元。任务通过使用活动或函数、与其他支持的活动或 AWS Lambda 函数集成 AWS 服务，或者通过调用第三方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中致电第三方。

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

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

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

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

活动

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

活动ResourceARNs使用以下语法。

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

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

Lambda 函数

Lambda 任务使用执行函数。 AWS Lambda要指定 Lambda 函数，请使用字段中的 ARN Lambda 函数。Resource

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

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

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

以下Resource字段语法是与 Lambda 函数 AWS 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 支持的 AWS 服务

当您引用连接的资源时，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"
}

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

在此示例中，当 AWS Glue 作业完成时，下一个状态将运行。

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

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

Task 状态的“凭证”字段示例

指定硬编码角色 IAM ARN

以下示例指定了目标IAM角色，状态机的执行角色必须担任该角色才能访问名为的跨账户 Lambda 函数。Echo在此示例中，目标角色ARN被指定为硬编码值。

{
  "StartAt": "Cross-account call",
  "States": {
    "Cross-account call": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn": "arn:aws:iam::111122223333:role/LambdaRole"
      },
      "Parameters": {
        "FunctionName": "arn:aws:lambda:us-east-2:111122223333:function:Echo"
      },
      "End": true
    }
  }
}

指定JSONPath为IAM角色 ARN

以下示例指定了一个JSONPath值，该值将在运行ARN时解析为IAM角色。

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "$.roleArn"
      },
      ...
    }
  }
}

将内部函数指定为角色 IAM ARN

以下示例使用States.Format内部函数，该函数在运行时解析为IAM角色ARN。

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "States.Format('arn:aws:iam::{}:role/ROLENAME', $.accountId)"
      },
      ...
    }
  }
}