ワークフロー実行の修復と再開

https://console.aws.amazon.com/glue/ で AWS Glue コンソール を開きます。

ワークフローを表示し、その実行を再開するためのアクセス許可を持つユーザーとして、サインインします。

ナビゲーションペインで、[Workflows] (ワークフロー) をクリックします。

ワークフローを選択し、[History] (履歴) タブを選択します。

部分的にしか実行されていないワークフロー実行を選択し、[View run details] (実行の詳細を表示する) をクリックします。

実行グラフで、再起動しワークフロー実行の再開ポイントとする、最初の (または唯一の) ノードを選択します。

グラフの右側にある詳細ペインで、[Resume] (再開) チェックボックスをオンにします。

ノードの色が変わり、右上に小さな [Resume] (再開) アイコンが表示されます。

再起動する追加のノードについて、前述の 2 つのステップを完了します。

[Resume run] (実行を再開) をクリックします。

glue:ResumeWorkflowRun IAM アクセス許可が付与されていることを確認します。

再起動するノードのノード ID を取得します。

1. 元のワークフロー実行のために、get-workflow-run コマンドを実行します。ワークフロー名と実行 ID を指定し、次の例に示すように、--include-graph オプションを追加します。コンソールの [History] (履歴) タブから実行 ID を取得します。もしくは get-workflow コマンドを実行し取得します。

   aws glue get-workflow-run --name cloudtrailtest1 --run-id wr_a07e55f2087afdd415a404403f644a4265278f68b13ba3da08c71924ebe3c3a8 --include-graph
   

   このコマンドは、グラフのノードとエッジを大きな JSON オブジェクトとして返します。

2. ノードオブジェクトの Type および Name プロパティごとに、対象としているノードを見つけます。

   次に、出力されるノードオブジェクトの例を示します。

   {
       "Type": "JOB",
       "Name": "test1_post_failure_4592978",
       "UniqueId": "wnode_d1b2563c503078b153142ee76ce545fe5ceef66e053628a786ddd74a05da86fd",
       "JobDetails": {
           "JobRuns": [
               {
                   "Id": "jr_690b9f7fc5cb399204bc542c6c956f39934496a5d665a42de891e5b01f59e613",
                   "Attempt": 0,
                   "TriggerName": "test1_aggregate_failure_649b2432",
                   "JobName": "test1_post_failure_4592978",
                   "StartedOn": 1595358275.375,
                   "LastModifiedOn": 1595358298.785,
                   "CompletedOn": 1595358298.785,
                   "JobRunState": "FAILED",
                   "PredecessorRuns": [],
                   "AllocatedCapacity": 0,
                   "ExecutionTime": 16,
                   "Timeout": 2880,
                   "MaxCapacity": 0.0625,
                   "LogGroupName": "/aws-glue/python-jobs"
               }
           ]
       }
   }

3. ノードオブジェクトの UniqueId プロパティから、ノード ID を取得します。

resume-workflow-run コマンドを実行します。次の例に示すように、ワークフロー名、実行 ID、およびノード ID のスペース区切りのリストを指定します。

aws glue resume-workflow-run --name cloudtrailtest1 --run-id wr_a07e55f2087afdd415a404403f644a4265278f68b13ba3da08c71924ebe3c3a8 --node-ids wnode_ca1f63e918fb855e063aed2f42ec5762ccf71b80082ae2eb5daeb8052442f2f3  wnode_d1b2563c503078b153142ee76ce545fe5ceef66e053628a786ddd74a05da86fd

このコマンドは、再開された (新しい) ワークフローの実行の ID と、開始されるノードのリストを出力します。

{
    "RunId": "wr_2ada0d3209a262fc1156e4291134b3bd643491bcfb0ceead30bd3e4efac24de9",
    "NodeIds": [
        "wnode_ca1f63e918fb855e063aed2f42ec5762ccf71b80082ae2eb5daeb8052442f2f3"
    ]
}

この例での resume-workflow-run コマンドでは再起動するノード 2 つをリストしていますが、出力例では 1 つのノードのみが再起動されると表示していることに注意してください。これは、1 つのノードが他のノードの下流にあり、いずれにせよ、この下流のノードはワークフローの通常のフローによって再開されるためです。