FetchGCSObject 2025.10.9.21 — Google Cloud Storage 객체 가져오기 프로세서
FetchGCSObject 2025.10.9.21 — Google Cloud Storage 객체 가져오기 프로세서
FetchGCSObject 프로세서는 Google Cloud 버킷에서 파일을 가져와요. ListGCSBucket과 함께 사용하도록 설계됐어요.
출처: Snowflake 문서
본문
기능 — 일반 공개 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP의 상용 리전에서 모든 계정에 제공돼요.
Openflow BYOC 배포는 AWS의 상용 리전에서 모든 계정에 제공돼요.
Bundle
org.apache.nifi | nifi-gcp-nar
Description
Google Cloud 버킷에서 파일을 가져와요. ListGCSBucket과 함께 사용하도록 설계됐어요.
Tags
fetch, gcs, google, google cloud, storage
Input Requirement
REQUIRED
Supports Sensitive Dynamic Properties
false
Properties
| Property | Description |
|---|---|
| GCP Credentials Provider Service | Google Cloud Platform 자격 증명을 얻는 데 사용하는 Controller Service예요 |
| gcp-project-id | Google Cloud 프로젝트 ID |
| gcp-retry-count | failure 관계로 라우팅하기 전에 수행할 재시도 횟수 |
| gcs-bucket | 객체의 버킷 |
| gcs-generation | 다운로드할 객체의 generation. 설정하지 않으면 최신 generation이 다운로드돼요 |
| gcs-key | 객체의 이름 |
| gcs-object-range-length | Range Start부터 시작해 객체에서 다운로드할 바이트 수예요. 빈 값이거나 객체 끝을 넘어서는 값이면 객체 끝까지 읽어요 |
| gcs-object-range-start | 객체에서 읽기를 시작할 바이트 위치예요. 빈 값이거나 0이면 객체의 시작 부분부터 읽기 시작해요 |
| gcs-server-side-encryption-key | 객체가 암호화된 AES256 키 (base64로 인코딩됨) |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요 |
| storage-api-url | 기본 스토리지 URL을 재정의해요. 대체 Storage API URL을 구성하면 Google의 Private Service Connections 문서에 설명된 대로 요청의 HTTP Host 헤더도 재정의돼요 |
Relationships
| Name | Description |
|---|---|
| failure | Google Cloud Storage 작업이 실패하면 FlowFile이 이 관계로 라우팅돼요 |
| success | Google Cloud Storage 작업이 성공한 후 FlowFile이 이 관계로 라우팅돼요 |
Writes attributes
| Name | Description |
|---|---|
| filename | 파일의 이름으로, 가능하면 Content-Disposition 응답 헤더에서 파싱돼요 |
| gcs.bucket | 객체의 버킷 |
| gcs.key | 객체의 이름 |
| gcs.size | 객체의 크기 |
| gcs.cache.control | 객체의 데이터 캐시 제어 |
| gcs.component.count | 객체를 구성하는 컴포넌트 수 |
| gcs.content.disposition | 객체의 데이터 콘텐츠 처리(disposition) |
| gcs.content.encoding | 객체의 콘텐츠 인코딩 |
| gcs.content.language | 객체의 콘텐츠 언어 |
| mime.type | 객체의 MIME/Content-Type |
| gcs.crc32c | 빅엔디언 순서로 base64로 인코딩된 객체 데이터의 CRC32C 체크섬 |
| gcs.create.time | 객체의 생성 시간 (밀리초) |
| gcs.update.time | 객체의 마지막 수정 시간 (밀리초) |
| gcs.encryption.algorithm | 객체를 암호화하는 데 사용된 알고리즘 |
| gcs.encryption.sha256 | 객체를 암호화하는 데 사용된 키의 SHA256 해시 |
| gcs.etag | 객체의 HTTP 1.1 Entity 태그 |
| gcs.generated.id | 객체에 서비스가 생성한 id |
| gcs.generation | 객체의 데이터 generation |
| gcs.md5 | base64로 인코딩된 객체 데이터의 MD5 해시 |
| gcs.media.link | 객체에 대한 미디어 다운로드 링크 |
| gcs.metageneration | 객체의 metageneration |
| gcs.owner | 객체의 소유자 (업로더) |
| gcs.owner.type | 객체 업로더의 ACL 엔티티 타입 |
| gcs.acl.owner | 객체에 소유자 접근 권한이 있는 ACL 엔티티의 쉼표로 구분된 목록. 엔티티는 이메일 주소, 도메인 또는 프로젝트 ID가 될 수 있어요 |
| gcs.acl.writer | 객체에 쓰기 접근 권한이 있는 ACL 엔티티의 쉼표로 구분된 목록. 엔티티는 이메일 주소, 도메인 또는 프로젝트 ID가 될 수 있어요 |
| gcs.acl.reader | 객체에 읽기 접근 권한이 있는 ACL 엔티티의 쉼표로 구분된 목록. 엔티티는 이메일 주소, 도메인 또는 프로젝트 ID가 될 수 있어요 |
| gcs.uri | 객체의 URI를 문자열로 표현한 값 |
Use Cases Involving Other Components
| Retrieve all files in a Google Compute Storage (GCS) bucket |
|---|
| Google Compute Storage (GCS) 버킷의 모든 파일을 가져와요 |
See also
- org.apache.nifi.processors.gcp.storage.DeleteGCSObject
- org.apache.nifi.processors.gcp.storage.ListGCSBucket
- org.apache.nifi.processors.gcp.storage.PutGCSObject