FetchS3Object 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-aws-nar
설명¶
S3 오브젝트의 내용을 가져와 FlowFile 의 내용으로 기록합니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
AWS 자격 증명 공급자 서비스 |
AWS 자격 증명 공급자를 획득하는 데 사용되는 컨트롤러 서비스 |
버킷 |
상호 작용할 S3 버킷 |
통신 시간 제한 |
AWS 에 연결을 설정하거나 AWS 에서 데이터를 수신하기 위해 시간 초과 전에 대기해야 하는 시간입니다. |
Endpoint Override URL |
스키마, 호스트, 포트, 경로 등 기본값인 AWS 대신 사용할 엔드포인트 URL 을 설정합니다. AWS 라이브러리는 AWS 리전을 기반으로 엔드포인트 URL 을 선택하지만, 이 속성은 선택한 엔드포인트 URL 을 재정의하여 다른 S3 호환 엔드포인트와 함께 사용할 수 있도록 합니다. |
오브젝트 키 |
사용할 S3 오브젝트 키입니다. 이는 기존 파일 시스템의 파일 이름과 유사합니다. |
리전 |
연결할 AWS 리전입니다. |
SSL 컨텍스트 서비스 |
공급자가 제공하는 경우 연결을 만드는 데 사용할 선택적 SSL 컨텍스트 서비스를 지정합니다 |
Signer Override |
AWS S3 라이브러리는 기본적으로 서명 버전 4를 사용하지만 이 속성을 사용하면 버전 2 서명자를 지정하여 이전 S3 호환 서비스를 지원하거나 사용자 정의 서명자 구현을 플러그인할 수도 있습니다. |
버전 |
다운로드할 오브젝트의 버전 |
custom-signer-class-name |
사용자 지정 서명자 클래스의 정규화된 클래스 이름입니다. 서명자는 com.amazonaws.auth.Signer 인터페이스를 구현해야 합니다. |
custom-signer-module-location |
사용자 지정 서명자의 JAR 파일 및 종속성(있는 경우)을 포함하는 파일 및/또는 디렉터리 경로를 쉼표로 구분한 목록입니다. |
encryption-service |
요청을 구성하는 데 사용되는 암호화 서비스 컨트롤러를 지정합니다. PutS3Object: 이전 버전과의 호환성을 위해 ‘서버 측 암호화’가 설정된 경우 이 값은 무시됩니다. FetchS3Object: 서버 측 고객 키, 클라이언트 측 KMS 및 클라이언트 측 고객 키 암호화의 경우에만 구성해야 합니다. |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
range-length |
오브젝트에서 다운로드할 바이트 수(범위 시작부터 시작)입니다. 빈 값 또는 오브젝트 끝을 넘어 확장된 값은 오브젝트의 끝까지 읽습니다. |
range-start |
오브젝트에서 읽기를 시작할 바이트 위치입니다. 빈 값 또는 0 값은 오브젝트의 시작 부분에서 읽기가 시작됩니다. |
requester-pays |
true이면 요청자가 S3 버킷에서 오브젝트 검색과 관련된 모든 요금 지불에 동의함을 나타냅니다. 이렇게 하면 ‘x-amz-request-payer’ 헤더가 ‘요청자’로 설정됩니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
프로세서가 지정된 FlowFile 을 처리할 수 없는 경우 이 관계로 라우팅됩니다. |
성공 |
FlowFiles 은 성공적으로 처리된 후 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
s3.url |
S3 오브젝트에 액세스하는 데 사용할 수 있는 URL |
s3.bucket |
S3 버킷의 이름 |
경로 |
파일 경로 |
absolute.path |
파일 경로 |
파일 이름 |
파일 이름 |
hash.value |
파일의 MD5 합 |
hash.algorithm |
MD5 |
mime.type |
S3가 콘텐츠 유형/MIME 유형을 제공하는 경우, 이 특성은 해당 파일을 보유합니다 |
s3.etag |
파일이 변경되었는지 확인하는 데 사용할 수 있는 ETag |
s3.exception |
프로세서 실행 중에 throw된 예외의 클래스 이름입니다 |
s3.additionalDetails |
S3가 실패한 작업에서 세부 정보를 제공했습니다 |
s3.statusCode |
실패한 작업의 HTTP 오류 코드(사용 가능한 경우) |
s3.errorCode |
실패한 작업의 S3 명칭 |
s3.errorMessage |
실패한 작업의 S3 예외 메시지 |
s3.expirationTime |
파일에 만료 날짜가 있는 경우 이 특성이 설정되며, UTC 시간으로 epoch 이후 밀리초가 포함됩니다 |
s3.expirationTimeRuleId |
이 오브젝트의 만료 시간을 지정하는 규칙의 ID |
s3.sseAlgorithm |
오브젝트의 서버 측 암호화 알고리즘입니다 |
s3.version |
S3 오브젝트의 버전 |
s3.encryptionStrategy |
S3 오브젝트를 저장하는 데 사용되는 암호화 전략의 이름(암호화되어 있는 경우) |
사용 사례¶
S3에서 특정 파일 가져오기 |
다른 구성 요소가 포함된 사용 사례¶
S3 버킷에 있는 모든 파일 검색하기 |
S3에서 지정된 기준을 충족하는 파일만 검색 |
S3 버킷에 도착한 새 파일 검색 |