PutGCSObject 프로세서
PutGCSObject 프로세서
PutGCSObject는 FlowFile의 내용을 Google Cloud Storage의 객체로 기록하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-gcp-nar
설명
FlowFile의 내용을 Google Cloud Storage의 객체로 기록해요.
Tags archive, gcs, google, google cloud, put
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| File Resource Service | 전송할 로컬 리소스에 대한 접근을 제공하는 File Resource Service예요. |
| GCP Credentials Provider Service | Google Cloud Platform 자격 증명을 얻는 데 사용하는 Controller Service예요. |
| Resource Transfer Source | 전송할 내용의 소스예요. |
| gcp-project-id | Google Cloud 프로젝트 ID예요. |
| gcp-retry-count | failure 관계로 라우팅되기 전에 재시도할 횟수예요. |
| gcs-bucket | 객체의 버킷이에요. |
| gcs-content-disposition-type | 객체에 첨부할 RFC-6266 Content Disposition 타입이에요. |
| gcs-content-type | 파일의 Content Type이에요. 예: text/plain. |
| gcs-key | 객체의 이름이에요. |
| gcs-object-acl | 업로드한 객체에 첨부할 Access Control이에요. 제공하지 않으면 버킷 기본값으로 되돌아가요. |
| gcs-object-crc32c | 서버 측 검증을 위한 파일의 CRC32C 체크섬(Base64, 빅엔디언 순서)이에요. |
| gcs-overwrite-object | false면 객체가 존재하지 않을 때에만 GCS 업로드가 성공해요. |
| gcs-server-side-encryption-key | 객체의 서버 측 암호화에 사용하는 AES256 암호화 키(Base64 인코딩)예요. |
| gzip.content.enabled | 전송 중 GZIP 압축을 원하는지 GCS Blob Writer에 알려줘요. false는 압축하지 않는다는 뜻이며 많은 경우 성능을 높여줘요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요. |
| storage-api-url | 기본 Storage URL을 덮어써요. 대체 Storage API URL을 설정하면 Google의 Private Service Connections 문서에 설명된 대로 요청의 HTTP Host 헤더도 덮어써요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | Google Cloud Storage 연산이 실패하면 FlowFile이 이 관계로 라우팅돼요. |
| success | Google Cloud Storage 연산이 성공하면 FlowFile이 이 관계로 라우팅돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| gcs.bucket | 객체의 버킷이에요. |
| gcs.key | 객체의 이름이에요. |
| gcs.size | 객체의 크기예요. |
| gcs.cache.control | 객체의 데이터 캐시 제어값이에요. |
| gcs.component.count | 객체를 구성하는 컴포넌트 수예요. |
| gcs.content.disposition | 객체의 데이터 Content Disposition이에요. |
| gcs.content.encoding | 객체의 Content Encoding이에요. |
| gcs.content.language | 객체의 Content Language예요. |
| mime.type | 객체의 MIME/Content-Type이에요. |
| gcs.crc32c | 객체 데이터의 CRC32C 체크섬이며 base64 빅엔디언 순서로 인코딩돼요. |
| gcs.create.time | 객체의 생성 시각(밀리초)이에요. |
| gcs.update.time | 객체의 마지막 수정 시각(밀리초)이에요. |
| gcs.encryption.algorithm | 객체를 암호화하는 데 사용된 알고리즘이에요. |
| gcs.encryption.sha256 | 객체를 암호화하는 데 사용된 키의 SHA256 해시예요. |
| gcs.etag | 객체의 HTTP 1.1 Entity tag예요. |
| gcs.generated.id | 서비스가 생성한 객체용 ID예요. |
| gcs.generation | 객체의 데이터 세대(generation)예요. |
| gcs.md5 | 객체 데이터의 MD5 해시이며 base64로 인코딩돼요. |
| gcs.media.link | 객체의 미디어 다운로드 링크예요. |
| gcs.metageneration | 객체의 metageneration이에요. |
| gcs.owner | 객체의 소유자(업로더)예요. |
| gcs.owner.type | 객체 업로더의 ACL 엔티티 타입이에요. |
| gcs.uri | 문자열로 나타낸 객체의 URI예요. |