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	행을 가져오는 데 지금까지 걸린 시간(밀리초)입니다