修復和繼續工作流程執行

開啟位於 https://console.aws.amazon.com/glue/ 的 AWS Glue 主控台。

以具有檢視工作流程和繼續工作流程執行之許可的使用者身分登入。

在導覽窗格中，選擇 Workflows (工作流程)。

選擇工作流程，然後選擇 History (歷程記錄) 索引標籤。

選擇只有部分執行的工作流程執行，然後選擇 View run details (檢視執行詳細資訊)。

在執行圖中，選取您想要重新啟動以及您想要從其繼續工作流程執行的第一個 (或唯一) 節點。

在圖形右側的詳細資訊窗格中，選取 Resume (繼續) 核取方塊。

節點會變更顏色，並在右上角顯示一個小的繼續圖示。

對於要重新啟動的任何其他節點，完成先前兩個步驟。

選擇 Resume run (繼續執行)。

請確定您具備 glue:ResumeWorkflowRun IAM 許可。

擷取您要重新啟動之節點的節點 ID。

1. 執行原始工作流程執行的 get-workflow-run 命令。提供工作流程名稱和執行 ID，然後新增 --include-graph 選項，如下列範例所示。從主控台的 History (歷史記錄) 索引標籤，或執行 get-workflow 命令來取得執行 ID。

   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 命令列出會重新啟動兩個節點，但範例輸出指出只有一個節點會重新啟動。這是因為一個節點位於另一個節點的下游，而下游節點仍會由工作流程的正常流程重新啟動。