PutSnowflakeInternalStageFile 프로세서
PutSnowflakeInternalStageFile 프로세서
PutSnowflakeInternalStageFile은 파일을 Snowflake 내부 스테이지에 넣는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명
파일을 Snowflake 내부 스테이지에 넣어요. 내부 스테이지는 미리 Snowflake 계정에 만들어져 있어야 해요.
Tags connection, database, jdbc, openflow, snowflake, snowpipe
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Compression Enabled | 파일을 업로드하기 전에 데이터를 압축하려면 true로 설정해요. |
| Database | 기본적으로 사용할 데이터베이스예요. 연결 문자열에 'db=DATABASE_NAME'을 전달하는 것과 같아요. |
| File Name | 사용할 대상 파일 이름이에요. |
| File Prefix | 스테이지에 데이터를 업로드할 경로 접두사예요. |
| Internal Stage Type | 사용할 내부 스테이지 타입이에요. |
| Schema | 기본적으로 사용할 스키마예요. 연결 문자열에 'schema=SCHEMA'를 전달하는 것과 같아요. |
| Snowflake Connection Service | Snowflake에 접근하기 위한 데이터베이스 연결 서비스예요. |
| Stage | 파일을 넣을 Snowflake 계정의 내부 스테이지 이름이에요. |
| Table | Snowflake 계정의 테이블 이름이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 실패한 PUT 연산의 FlowFile용 관계예요. |
| success | 성공한 PUT 연산의 FlowFile용 관계예요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| snowflake.staged.file.path | 스테이징된 파일 경로예요. |