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

タスクワークフローの状態

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 状態定義内で指定できる次のタスクタイプをサポートしています。

タスクタイプを指定するには、タスク状態定義の ARN Resourceフィールドにタスクタイプを指定します。次の例は、Resource フィールドの構文を示しています。サードパーティーの を呼び出すタスクタイプを除くすべてのタスクタイプはAPI、次の構文を使用します。HTTP タスクの構文については、「」を参照してくださいStep Functions ワークフローAPIsでサードパーティーを呼び出す。

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

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

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

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

アクティビティ

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

アクティビティでは、次の構文ResourceARNsを使用します。

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

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

Lambda 関数

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

統合のタイプ (最適化された統合または AWS SDK 統合 ) Lambda 関数の指定に使用する場合、Lambda 関数の Resourceフィールドの構文は異なります。

次の Resource フィールド構文は、Lambda 関数と最適化された統合の例です。

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

次のResourceフィールド構文は、 の例です。 AWS 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") で識別される状態に送信されます。

サポートされる 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
    }
  }
}

タスク状態フィールド

[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

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

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

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

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

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

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

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