AWS Data Pipeline 신규 고객은 더 이상 이용할 수 없습니다. 의 기존 고객 AWS Data Pipeline 정상적으로 서비스를 계속 사용할 수 있습니다. 자세히 알아보기
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
존재함
데이터 노드 객체가 존재하는지 확인합니다.
참고
대신에 시스템이 관리하는 사전 조건을 사용할 것을 권장합니다. 자세한 내용은 사전 조건 단원을 참조하십시오.
예
다음은 이 객체 유형의 예제입니다. InputData
객체는 이 Ready
객체뿐 아니라 동일한 파이프라인 정의 파일에서 정의하려는 다른 객체를 참조합니다. CopyPeriod
는 Schedule
객체입니다.
{ "id" : "InputData", "type" : "S3DataNode", "schedule" : { "ref" : "CopyPeriod" }, "filePath" : "s3://example-bucket/InputData/#{@scheduledStartTime.format('YYYY-MM-dd-hh:mm')}.csv", "precondition" : { "ref" : "Ready" } }, { "id" : "Ready", "type" : "Exists" }
구문
선택 필드 | 설명 | 슬롯 유형 |
---|---|---|
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 "} |
emrStepLog | EMR단계 로그는 EMR 활동 시도 시에만 사용할 수 있습니다. | String |
errorId | 이 개체가 실패한 errorId 경우 | String |
errorMessage | 이 개체가 실패한 errorMessage 경우 | String |
errorStackTrace | 이 객체가 실패한 경우의 오류 스택 트레이스입니다. | String |
hadoopJobLog | EMR기반 활동 시도 시 Hadoop 작업 로그를 사용할 수 있습니다. | String |
hostname | 작업 시도를 선택한 클라이언트의 호스트 이름입니다. | 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 |