CaptureChangeSqlServer 2025.5.31.15¶

Pacote¶

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

Descrição¶

Lê eventos CDC de um banco de dados do servidor SQL. O processador consulta periodicamente as tabelas de rastreamento de alterações no banco de dados, mas somente para as tabelas fornecidas pelo TableStateService. O processador mantém um estado do último evento processado para cada tabela. O processador move a posição após cada tabela processada. O processador oferece suporte a multithread. O número de threads e o limite de conexão configurados no pool definem coletivamente o limite superior de conexões abertas ao banco de dados de origem. O processador gera dois tipos de FlowFiles: DDLs que contém o esquema inicial de uma tabela e, em seguida, sempre que o esquema é alterado, e DMLs com registros que representam alterações nos dados da tabela. Um FlowFile sempre representa os dados relacionados a uma única tabela. O DDL com o esquema é gravado no conteúdo do FlowFile como um objeto JSON, em um formato como: { «columns»: [ { «name»: «<columnName>», «type»: «<snowflakeType>», «nullable»: <true|false>, «scale»: <scale>, «precision»: <precision> }, …], «primaryKeys»: [«<primaryKey1>», «<primaryKey2>», …]}. Os registros DML são estruturados como: { «primaryKeys»: { «<column>»: <value>, … }, «payload»: { «<column>»: <value>, … }, «metadata»: { «<column>»: <value>, … }}

Tags¶

cdc, event, jdbc, sql, sql server

Requisito de entrada¶

FORBIDDEN

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Gerenciamento do estado¶

Relações¶