修复和恢复工作流运行

恢复工作流程运行(控制台)

1. 通过以下网址打开 AWS Glue 控制台：https://console.amazonaws.cn/glue/。

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

   注意

   要恢复工作流运行,您需要 glue:ResumeWorkflowRun AWS Identity and Access Management (人IAM)权限。

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

3. 选择工作流程,然后选择 历史 选项卡。

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

5. 在运行图表中,选择要重新启动的第一个(或仅)节点,以及要恢复从运行工作流的节点。

6. 在图表右侧的详细信息窗格中,选择 恢复 复选框。

   

   节点会更改颜色,并在右上方显示一个小的恢复图标。

   

7. 要重新启动任何附加节点,请完成前两个步骤。

8. 选择 恢复运行.

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

1. 确保您拥有 glue:ResumeWorkflowRun IAM 权限。

2. 检索节点 IDs 用于要重新启动的节点。

   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和节点列表 IDs 用空格分隔,如以下示例所示。

   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 命令列出了两个要重新启动的节点,示例输出表示仅一个节点将被重新启动。这是因为一个节点位于另一个节点的下游,并且下游节点无论如何都会通过工作流的正常流程重新启动。