FetchTableSnapshot 2025.5.31.15

번들

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

설명

데이터베이스에서 테이블의 스냅샷을 가져옵니다. 스냅샷은 테이블의 기본 키 열을 사용하여 일괄적으로 행을 가져오는 방식으로 증분적으로 가져옵니다. 기본 키가 없는 테이블 복제는 지원되지 않습니다. 스냅샷은 지정된 Record Writer 형식으로 FlowFile 에 기록됩니다. 입력 FlowFile 은 { “columns”: [{ “name”: “<column name>”, “type”: “<column type>” }, { “name”: “<column name>”, “type”: “<column type>” }, … ], “primaryKeys”: [“<첫 번째 기본 키 열의 이름>”, “<두 번째 기본 키 열의 이름>”, …]} 형식의 테이블 스키마의 JSON 표현으로 구성될 것으로 예상됩니다. 스키마에 지정된 열만 테이블에서 가져옵니다.

태그

database, fetch, rdbms, snapshot, snowflake, table

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

Connection Pool

데이터베이스 스냅샷을 가져오는 데 사용할 연결 풀입니다

Fetch Size

한 번에 메모리에 로딩되는 최대 행 수입니다

JDBC Driver Location

쉼표로 구분된 파일/폴더 목록 및/또는 URLs 드라이버 JAR 및 종속성(있는 경우)이 포함된 목록입니다. 예: ‘/var/tmp/postgresql-java-client-42.7.5.jar’

Max Batch Size

단일 배치에서 가져올 최대 행 수입니다

Record Writer

가져온 스냅샷을 작성하는 데 사용할 Record Writer

Schema Name

스냅샷을 가져올 스키마의 이름입니다

테이블 이름

스냅샷을 가져올 테이블의 이름입니다

관계

이름

설명

complete

스냅샷이 완료되면 원본 FlowFile 은 이 관계로 라우팅됩니다

실패

FlowFile 로 표시된 테이블에서 데이터를 검색할 수 없는 경우 FlowFile 은 이 관계로 라우팅됩니다.

retryable failure

FlowFile 로 표시된 테이블에서 데이터를 검색할 수 없지만 향후 가능할 것으로 예상되는 경우 FlowFile 은 관계로 라우팅됩니다.

rows

FlowFile 로 표시되는 테이블에서 스냅샷이 성공적으로 검색되면 행이 이 관계로 라우팅됩니다.

Writes 특성

이름

설명

snapshot.complete

스냅샷이 완료되었는지 여부를 나타냅니다

rows.total.fetched

테이블에 대해 가져온 총 행 수입니다

rows.delta.fetched

마지막 반복에서 테이블에 대해 가져온 행 수입니다

start.row.index

지정된 반복에 대한 스냅샷 내 첫 번째 행의 인덱스(0부터 시작)입니다

last.row.index

지정된 반복에 대한 스냅샷 내 마지막 행의 인덱스(0부터 시작)입니다

fetch.delta.time.in.millis

마지막 반복에서 행을 가져오는 데 걸린 시간(밀리초)입니다

fetch.total.time.in.millis

행을 가져오는 데 지금까지 걸린 시간(밀리초)입니다