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

Task 工作流程状态

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

亚马逊州语言通过将状态类型设置为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 状态定义中指定这些类型：

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

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

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

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

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

活动

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

活动Resource ARNs 使用以下语法。

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

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

Lambda 函数

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

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

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

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

以下Resource字段语法是 AWS 软件开发工具包与 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 支持的 AWS 服务

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

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

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 角色，状态机的执行角色必须担任该角色才能访问名为 Echo 的跨账户 Lambda 函数。在此示例中，目标角色 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 值，该值将在运行时解析为 IAM 角色 ARN。

{
  "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)"
      },
      ...
    }
  }
}