Step Functions で実行される Redriving マップ実行

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

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

失敗した子ワークフローは、親ワークフローのマップ実行で redriving できます。redriven された親ワークフローは、分散マップを含むすべての失敗状態を redrives します。親ワークフローが実行を完了したときに、ステートの <stateType>Entered イベントに対応する <stateType>Exited イベントがない場合、親ワークフローは失敗した状態を再処理します。例えば、イベント履歴に MapStateEntered イベントの MapStateExited イベントが含まれていない場合は、親ワークフローを再処理して、マップ実行で失敗した子ワークフローの実行をすべて再処理できます。

ステートマシンに ItemReader (Map)、ResultWriter (Map)、またはその両方にアクセスするために必要な権限がない場合、マップ実行は開始されないか、最初の実行試行に失敗します。親ワークフローの最初の実行時にマップ実行が開始されなかった場合、親ワークフローを再処理すると初めてマップ実行が開始されます。これを解決するには、必要なアクセス許可をステートマシンロールに追加し、次に親ワークフローを redrive します。必要なアクセス許可を追加せずに親ワークフローを再処理すると、新しいマップ実行の実行を開始しようとしますが、再び失敗します。必要なアクセス許可については、「分散マップ状態を使用するための IAM ポリシー」を参照してください。

マップ実行での子ワークフローの対象を再処理する

次の条件が満たされる場合、マップ実行で失敗した子ワークフローの実行を再処理できます。

次の場合、元の実行試行でマップ実行が失敗しても、新しいマップ実行が開始され、既存のマップ実行は再処理されません。

マップ実行は、親ワークフローが停止またはタイムアウトした後も引き続き実行できます。これらのシナリオでは、再処理はすぐには実行されません。

このような場合、実行中のマップ実行は、再処理を試行する前に操作を完了します。

子ワークフローの実行再処理動作

マップ実行での再処理された子ワークフローの実行は、次の表に示すような動作を示します。

マップ実行を再処理していて、同時実行数の制限に達した場合、そのマップ実行での子ワークフロー実行は保留ステートに移行します。マップ実行の実行ステータスも [保留中の redrive] ステートに移行します。指定した同時実行数の制限により子ワークフローの実行回数が増えるまで、実行は、[保留中の redrive] ステートのままになります。

例えば、ワークフロー内の分散マップの同時実行数の上限が 3000 件で、再実行される子ワークフローの数が 6000 件だとします。これにより、3000 件の子ワークフローが並行して実行され、残りの 3000 件のワークフローは [保留中のリドライブ] ステートのままになります。3000 件の子ワークフローの最初のバッチが実行を完了すると、残りの 3000 件の子ワークフローが実行されます。

マップ実行の実行が完了するか中止されると、[保留中の redrive] ステートの子ワークフロー実行数は 0 にリセットされます。

マップ実行再処理で使用される入力のシナリオ

最初の実行時に分散マップにどのように入力したかに応じて、再処理されたマップ実行では次の表に示すように入力を使用します。

マップ実行を再処理する IAM アクセス許可

Step Functions には、マップ実行を再処理するための適切なアクセス許可が必要です。次の IAM ポリシーの例では、マップ実行の再処理に必要な最小限の権限をステートマシンに付与しています。イタリック体のテキストを、リソース固有の情報に必ず置き換えてください。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "states:RedriveExecution"
      ],
      "Resource": "arn:aws:states:us-east-2:123456789012:execution:myStateMachine/myMapRunLabel:*"
    }
  ]
}

コンソールでのマップ実行の再処理

以下のイメージは、分散マップを含むステートマシンの実行グラフを示しています。マップ実行が失敗したため、この実行は失敗しました。マップ実行を再処理するには、親ワークフローを再処理する必要があります。

マップ実行を再処理したら、再処理された詳細は、コンソールで、または GetExecutionHistory および DescribeExecution API アクションを使用して調べることができます。redriven 実行の確認の詳細については、実行の詳細については、「再処理された実行内容を調べる」を参照してください。

RedrivingAPI を使用したマップ実行の再処理

親ワークフローの RedriveExecution API を使用して対象のマップ実行を再処理できます。この API は、マップ実行で失敗した子ワークフローの実行を再開します。

AWS Command Line Interface (AWS CLI) で、以下のコマンドを実行して、失敗したステートマシンの実行を再処理します。イタリック体のテキストを、リソース固有の情報に必ず置き換えてください。

aws stepfunctions redrive-execution --execution-arn arn:aws:states:us-east-2:123456789012:execution:myStateMachine:foo

マップ実行を redriven したら、redrive された詳細は、コンソールで、または DescribeMapRun API アクションを使用して調べることができます。マップ実行での標準ワークフロー実行の再処理の詳細を調べるには、GetExecutionHistory または DescribeExecution API アクションを使用できます。redriven 実行の確認の詳細については、実行の詳細については、「再処理された実行内容を調べる」を参照してください。

親ワークフローでログ記録を有効にしている場合は、Step Functions コンソールのマップ実行でエクスプレスワークフロー実行の再処理の詳細を確認できます。詳細については、「CloudWatch Logs を使用した Step Functions の実行履歴のログ記録」を参照してください。