AWS Data Pipeline 신규 고객은 더 이상 이용할 수 없습니다. 의 기존 고객 AWS Data Pipeline 정상적으로 서비스를 계속 사용할 수 있습니다. 자세히 알아보기
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
S3 KeyExists
Amazon S3 데이터 노드에 키가 존재하는지 확인합니다.
예
다음은 이 객체 유형의 예제입니다. s3Key 파라미터가 참조하는 키인 s3://mybucket/mykey가 존재하면 사전 조건이 트리거됩니다.
{ "id" : "InputReady", "type" : "S3KeyExists", "role" : "test-role", "s3Key" : "s3://mybucket/mykey" }
첫 번째 파이프라인이 종료되기를 기다리는 두 번째 파이프라인에서 S3KeyExists를 사전 조건으로 사용할 수도 있습니다. 그렇게 하려면 다음을 수행하세요.
-
첫 번째 파이프라인의 완료가 끝날 때 Amazon S3에 파일을 씁니다.
-
두 번째 파이프라인에서
S3KeyExists사전 조건을 생성합니다.
구문
| 필수 필드 | 설명 | 슬롯 유형 |
|---|---|---|
| 역할 | 사전 조건을 실행할 때 사용할 역할을 지정합니다. | String |
| s3Key | Amazon S3 키. | String |
| 선택 필드 | 설명 | 슬롯 유형 |
|---|---|---|
| attemptStatus | 원격 활동에서 가장 최근에 보고된 상태입니다. | String |
| attemptTimeout | 한 번 더 원격 작업을 완료하기 전의 제한 시간입니다. 이 시간을 설정하면 시작 후 설정된 시간 내에 완료되지 않는 원격 활동이 다시 시도됩니다. | 기간 |
| failureAndRerun모드 | 종속 요소에 장애가 있거나 재시도될 때의 소비자 노드 거동을 설명합니다. | 열거 |
| lateAfterTimeout | 파이프라인 시작 후 객체가 완료되어야 하는 경과 시간입니다. 스케줄 유형이 ondemand(으)로 설정되지 않은 경우에만 트리거됩니다. |
기간 |
| maximumRetries | 장애 시 시작되는 최대 시도 횟수입니다. | Integer |
| onFail | 현재 객체 장애 시 실행할 작업입니다. | 참조 객체, 예: "onFail“: {" ref”:” myActionId “} |
| onLateAction | 객체가 아직 예약되지 않았거나 아직 완료되지 않은 경우에 트리거되어야 하는 작업입니다. | 참조 객체, 예: "onLateAction“: {" ref”:” myActionId “} |
| onSuccess | 현재 객체 성공 시 실행할 작업입니다. | 참조 객체, 예: "onSuccess“: {" ref”:” myActionId “} |
| parent | 슬롯을 상속할 현재 객체의 부모입니다. | 참조 객체, 예: “부모”: {"ref”:” myBaseObject Id "} |
| preconditionTimeout | 아직 충족되지 않은 사전 조건이 '실패'로 표시되기 시작하는 기간. | 기간 |
| reportProgressTimeout | 원격 작업에서 reportProgress를 연속으로 호출하는 제한 시간입니다. 이것이 설정되면 지정 기간 동안 진행 상황을 보고하지 않는 원격 활동은 중단된 것으로 간주되어 재시도될 수 있습니다. |
기간 |
| retryDelay | 두 번의 연속 시도 사이의 제한 시간 간격입니다. | 기간 |
| 실행 시간 필드 | 설명 | 슬롯 유형 |
|---|---|---|
| @activeInstances | 현재 예약되어 있는 활성 인스턴스 객체의 목록입니다. | 참조 객체, 예: "activeInstances“: {" ref”:” myRunnableObject Id "} |
| @actualEndTime | 이 객체의 실행이 완료된 시간입니다. | DateTime |
| @actualStartTime | 이 객체의 실행이 시작된 시간입니다. | DateTime |
| cancellationReason | 이 객체가 취소된 cancellationReason 경우 | String |
| @cascadeFailedOn | 객체 실패가 발생한 종속 체인에 대한 설명입니다. | 참조 객체, 예: "cascadeFailedOn“: {" ref”:” myRunnableObject Id "} |
| currentRetryCount | 이번 시도에서 사전 조건을 시도한 횟수 | String |
| emrStepLog | EMR단계 로그는 EMR 활동 시도 시에만 사용할 수 있습니다. | String |
| errorId | 이 개체가 실패한 errorId 경우 | String |
| errorMessage | 이 개체가 실패한 errorMessage 경우 | String |
| errorStackTrace | 이 객체가 실패한 경우의 오류 스택 트레이스입니다. | String |
| hadoopJobLog | EMR기반 활동 시도 시 Hadoop 작업 로그를 사용할 수 있습니다. | String |
| hostname | 작업 시도를 선택한 클라이언트의 호스트 이름입니다. | String |
| lastRetryTime | 이번 시도 안에서 사전 조건을 시도한 마지막 횟수 | String |
| 노드 | 이 사전 조건이 실행 중인 노드 | 참조 개체 (예: “node”: {"ref”:” myRunnableObject Id "} |
| reportProgressTime | 원격 활동에서 진행 상황을 보고한 가장 최근 시간입니다. | DateTime |
| @scheduledEndTime | 객체의 일정 종료 시간 | DateTime |
| @scheduledStartTime | 객체의 일정 시작 시간 | DateTime |
| @상태 | 이 객체의 상태입니다. | String |
| @version | 객체와 함께 생성된 파이프라인 버전입니다. | String |
| @waitingOn | 이 객체가 대기 중인 종속 요소 목록에 대한 설명입니다. | 참조 객체, 예: "waitingOn“: {" ref”:” myRunnableObject Id "} |
| 시스템 필드 | 설명 | 슬롯 유형 |
|---|---|---|
| @오류 | 잘못 형성된 객체를 설명하는 오류 | String |
| @pipelineId | 이 객체가 속하는 파이프라인의 ID | String |
| @sphere | 객체의 타원 무늬는 수명 주기 내 위치를 나타냅니다. Component Objects는 Attempt Objects를 실행하는 Instance Objects를 야기합니다. | String |
참고
