UpdateSnowflakeStream 2025.10.2.19¶
Pacote¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
Descrição¶
Gerencia fluxos Snowflake criando, descartando ou substituindo-os com base na operação configurada. Os fluxos Snowflake capturam alterações de dados para tabelas e podem ser usados para rastrear alterações de DML ao longo do tempo.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Pool de conexões |
O pool de conexões a ser usado para se conectar ao Snowflake |
Resolução do identificador do objeto |
Controla como os identificadores de objetos de origem (esquemas, tabelas, colunas) são armazenados e consultados no Snowflake. Essa configuração determina se você precisará usar aspas duplas em suas consultas SQL. |
Nome do esquema |
O nome do esquema que contém o fluxo e/ou a tabela de origem |
Nome da tabela de origem |
O nome da tabela de origem do fluxo |
Parâmetros de criação de fluxo |
Parâmetros adicionais a serem incluídos na instrução CREATE STREAM. Por exemplo, “APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE” |
Nome de fluxo |
O nome do fluxo a ser criado, descartado ou substituído |
Tipo de atualização |
O tipo de operação de fluxo a ser executada |
Relações¶
Nome |
Descrição |
|---|---|
failure |
O FlowFile de entrada é encaminhado para esse relacionamento se não for possível concluir a operação do fluxo |
objeto não encontrado |
O FlowFile de entrada é encaminhado para esse relacionamento se o fluxo ou a tabela de origem especificado não existir. |
success |
O FlowFile de entrada é encaminhado para esse relacionamento após a operação do fluxo ter sido concluída com sucesso |