CaptureChangePostgreSQL 2025.5.31.15¶

번들¶

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

설명¶

PostgreSQL 데이터베이스에서 CDC 이벤트를 읽습니다.프로세서는 스트림에 도착하는 이벤트를 지속적으로 읽고 TableStateService 에서 제공하는 테이블과 관련된 이벤트를 필터링하고 나머지는 삭제합니다. 현재 이벤트 배치가 처리된 후 프로세서는 복제 슬롯 위치를 PostgreSQL 로 다시 확인하여 WAL 을 트리밍할 수 있도록 합니다. 프로세서는 테이블의 초기 스키마를 포함하고 그 이후 스키마가 변경될 때마다 생성되는 DDLs 및 테이블의 데이터 변경을 나타내는 레코드가 포함된 DMLs 등 두 가지 유형의 플로우 파일을 출력합니다. 하나의 플로우 파일은 항상 단일 테이블과 관련된 데이터를 나타냅니다. 스키마가 포함된 DDL 은 FlowFile 내용에 { “columns”: [ { “name”: “<columnName>”, “type”: “<snowflakeType>”, “nullable”: <true|false>, “scale”: <scale>, “precision”: <precision> }, … ], “primaryKeys”: [“<primaryKey1>”, “<primaryKey2>”, …]} 와 같은 형식의 JSON 오브젝트로 기록됩니다. DML 레코드의 구조는 { “primaryKeys”: { “<column>”: <value>, … }, “payload”: { “<column>”: <value>, … }, “metadata”: { “<column>”: <value>, … }} 입니다.

태그¶

cdc, event, jdbc, postgresql, sql

입력 요구 사항¶

FORBIDDEN

민감한 동적 속성 지원¶

false

속성¶

상태 관리¶

관계¶

Writes 특성¶