워크플로 실행 복구 및 재개

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 명령은 다시 시작할 2개의 노드를 나열했지만 예제 출력은 1개의 노드만 다시 시작됨을 나타냅니다. 이는 한 노드가 다른 노드의 다운스트림이었고, 다운스트림 노드는 워크플로의 정상적인 흐름에 따라 다시 시작되기 때문입니다.