翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

タスクの状態

Task 状態 ("Type": "Task") は、ステートマシンによって実行される単一の作業単位を表します。タスクは、アクティビティまたは AWS Lambda 関数を使用するか、サポートされている他の AWS のサービスと統合するか、Stripe などのサードパーティー API を呼び出して作業を実行します。

Amazon States Language は、ステートのタイプを Task に設定し、タスクにアクティビティ、Lambda 関数、またはサードパーティー API エンドポイントの Amazon リソースネーム (ARN) を指定することによりタスクを表します。次のタスク状態定義は、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 構文の詳細については、「サードパーティーの API を呼び出す」を参照してください。

タスク状態定義で、次の構文の斜体文字テキストを AWS リソース固有の情報に置き換えます。

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

次のリストでは、この構文の個々のコンポーネントについて説明します。

次のセクションでは、各タスクタイプの詳細を示します。

アクティビティ

アクティビティは、お客様によって実装およびホストされ、特定のタスクを実行するワーカー (プロセスまたはスレッド) を示します。標準ワークフローでのみサポートされ、Express ワークフローではサポートされません。

アクティビティ Resource ARN は以下の構文を使用します。

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

アクティビティの作成とワーカーの実装の詳細については、アクティビティを参照してください。

Lambda 関数

Lambda タスクは、 を使用して関数を実行します AWS Lambda。Lambda 関数を指定するには、Resource フィールドの Lambda 関数の ARN を使用します。

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") に送信されます。

サポートされる AWS のサービス

接続されたリソースをリファレンスすると、Step Functions によって、サポートされたサービスの API アクションが直接呼び出されます。Resource フィールドでサービスとアクションを指定します。

接続されたサービス Resource ARN では以下の構文を使用します。

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
    }
  }
}

タスク状態フィールド

[common state fields] (共通状態フィールド) に加えて、Task 状態には次のフィールドがあります。

Task 状態は、その状態で実行が終了する場合は End フィールドが true に設定されている必要があります。または、Next フィールドに、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"
}

タスク状態の認証情報フィールドの例

ハードコーディングされた IAM ロール ARN の指定

次の例では、ステートマシンの実行ロールが Echo という名前のクロスアカウント Lambda 関数にアクセスするために継承する必要がある、ターゲット IAM ロールを指定します。この例では、ターゲットロールの 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
    }
  }
}

IAM ロール ARN として JSONPath を指定

次の例では、実行時に IAM ロール ARN を解決する JSONPath 値を指定します。

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

組み込み関数を IAM ロール ARN として指定する

次の例では、実行時に IAM ロール ARN を解決する、States.Format 組み込み関数を使用しています。

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