修复和恢复工作流程运行

恢复工作流程运行（控制台）

1. 打开 AWS Glue 控制台，请访问https://console.aws.amazon.com/glue/。

   以具有查看工作流程和恢复工作流程运行权限的用户身份登录。

   注意

   要恢复工作流程运行，您需要glue:ResumeWorkflowRunAWS Identity and Access Management (IAM) 权限。

2. 在导航窗格中，选择工作流程。

3. 选择工作流程，然后选择历史记录选项卡。

4. 选择仅部分运行的工作流程运行，然后选择查看运行详细信息。

5. 在运行图中，选择要重新启动并且要从中恢复工作流运行的第一个（或唯一）节点。

6. 在图形右侧的详细信息窗格中，选择Resume”复选框。

   

   节点会改变颜色，并在右上角显示一个小简历图标。

   

7. 完成前面 2 个步骤，以使任何其他节点重新启动。

8. 选择恢复运行。

恢复工作流程运行 (AWS CLI)

1. 确保您具有glue:ResumeWorkflowRunIAM 权限。

2. 检索要重新启动的节点的节点 ID。

   1. 运行get-workflow-run命令进行原始工作流运行。提供工作流名称和运行 ID，然后添加--include-graph选项，如以下示例所示。获取运行 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. 获取节点 ID 从UniqueId属性。

3. 运行 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命令列出了两个要重新启动的节点，则示例输出指示只重新启动一个节点。这是因为一个节点位于另一个节点的下游，无论如何，下游节点都会被工作流的正常流程重新启动。