PutSnowpipeStreaming2 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-snowpipe-streaming-2-processors-nar
설명¶
줄 바꿈으로 구분된 JSON 형식의 레코드를 Snowpipe Streaming 버전 2를 사용하여 Snowflake 데이터베이스 파이프로 전송합니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
계정 |
조직 이름과 계정 이름이 [organization-name]-[account-name] 형식으로 지정된 Snowflake 계정 식별자 |
Authentication Strategy |
Snowflake 연결 인증 전략 |
채널 그룹 |
분할을 사용하여 고유한 Snowpipe Streaming 채널을 관리하기 위한 그룹입니다. |
채널 삽입 시간 제한 |
실패하기 전에 레코드 삽입을 재시도하는 최대 기간(상한 5분) |
데이터베이스 |
처리된 레코드에 대한 Snowflake 데이터베이스 대상 |
파일 조각 수 |
입력 FlowFiles에서 Snowpipe Streaming 수집을 위해 오브젝트 저장소로 전송된 최대 파일 조각 수입니다. 1에서 100 사이여야 합니다. |
파일 조각 크기 |
Snowpipe Streaming 수집을 위해 오브젝트 저장소로 전송된 각 파일 조각의 최대 크기(바이트)입니다. 1KB에서 256MB 사이여야 합니다. |
오프셋 토큰 끝 표현식 |
FlowFile에 대해 단조 증가 숫자로 가장 높은 오프셋 토큰을 생성하는 표현식 언어 정의 |
오프셋 토큰 레코드 포인터 |
마지막으로 커밋된 오프셋 토큰이 시작과 끝 경계 사이에 있을 때 필요한 각 레코드의 오프셋 토큰에 대한 JSON 포인터 |
오프셋 토큰 시작 표현식 |
FlowFile에 대해 단조 증가 숫자로 가장 낮은 오프셋 토큰을 생성하는 표현식 언어 정의 |
오프셋 추적 시간 제한 |
커밋된 오프셋 토큰에 대한 채널 상태를 폴링하는 최대 기간 |
파이프 |
처리된 레코드의 Snowflake Pipe 대상 |
개인 키 서비스 |
연결 인증을 위한 RSA 개인 키 서비스 |
스키마 |
처리된 레코드에 대한 Snowflake 스키마 대상 |
전송 전략 |
Snowpipe Streaming으로 레코드를 전송하는 전략 |
사용자 |
연결 인증을 위한 Snowflake 사용자 |
웹 클라이언트 서비스 공급자 |
HTTP 요청 및 응답 처리를 지원하는 웹 클라이언트 서비스 공급자 |
관계¶
이름 |
설명 |
|---|---|
실패 |
Snowflake에 업로드하지 못한 FlowFiles |
invalid |
Snowflake가 하나 이상의 유효하지 않은 행을 포함하는 것으로 식별하여 부분적으로 전송된 FlowFiles |
성공 |
Snowflake에 성공적으로 업로드된 FlowFiles |