FetchSourceTableSchema 2025.5.31.15

Pacote

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

Descrição

Obtém o esquema da tabela (ou seja, nomes de colunas, tipos de dados etc.) para uma determinada tabela em um banco de dados, convertendo os tipos de dados em tipos compatíveis com o Snowflake. 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>», …]}

Tags

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Serviço de filtro de colunas

Especifica o serviço de filtro de colunas a ser usado para filtrar colunas indesejadas

Pool de conexões

O pool de conexões a ser usado para buscar o esquema da tabela de origem

Nome do esquema

O nome do esquema no qual a tabela de origem está armazenada

Nome da tabela

O nome da tabela de origem

Relações

Nome

Descrição

failure

FlowFiles são encaminhados para essa relação caso o esquema da tabela de origem não possa ser obtido

success

FlowFiles são encaminhados para essa relação quando o esquema da tabela de origem é obtido com sucesso

tabela não encontrada

FlowFiles são roteados para essa relação quando a tabela de origem não existe

Grava atributos

Nome

Descrição

mime.type

applicativo/json

dbms.type

O tipo de sistema de gerenciamento de banco de dados (DBMS) no qual a tabela de origem está armazenada. Por exemplo, POSTGRESQL

primary.key.count

O número de chaves primárias na tabela de origem

column.count

O número de colunas na tabela de origem