UpdateSnowflakeDatabase 2025.5.31.15¶

Pacote¶

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

Descrição¶

Atualiza a definição de uma tabela Snowflake com base no esquema fornecido no FlowFile de entrada. Espera-se que o esquema esteja em JSON com o seguinte formato, independentemente de ser fornecido por meio do conteúdo do FlowFile ou especificado como uma propriedade: { «columns»: [ { «name»: «<column name>», «type»: «<column type>», «nullable»: <true/false>, «precision»: <precision, only for numeric type>, «scale»: <scale, only for numeric type> }, …], «primaryKeys»: [«<nome da primeira coluna de chave primária>», «<nome da segunda coluna de chave primária>», …]}

Tags¶

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Adicionar estratégia de coluna	A estratégia a ser usada quando o esquema de entrada tem uma coluna que não está presente na tabela existente
Adicionar estratégia de não nulo	A estratégia a ser usada quando o esquema de entrada tem uma restrição não nula que não está presente na tabela existente
Transformação de nome de coluna	Uma transformação opcional que pode ser aplicada aos nomes das colunas definidas no esquema. Essa transformação é aplicada aos nomes das colunas antes de serem comparados com as colunas existentes na tabela. Essa propriedade pode fazer referência às seguintes variáveis por meio da linguagem de expressão, além dos atributos: `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey`.
Estratégia de remoção de coluna	A estratégia a ser usada quando a tabela existente tem uma coluna que não está presente no esquema de entrada
Pool de conexões	O pool de conexões a ser usado para se conectar ao Snowflake
Criar fluxo	Se você deve ou não criar um Snowflake Stream para a tabela
Parâmetros de criação	Parâmetros adicionais a serem incluídos na instrução CREATE TABLE. Por exemplo, “CLUSTER BY (column_name)”
Esquema desejado	A definição do esquema/tabela desejado
Estratégia de descarte de coluna	A estratégia a ser usada quando a tabela existente tem uma coluna que não está presente no esquema de entrada
Estratégia de descarte de não nulo	A estratégia a ser usada quando a tabela existente tem uma restrição não nula que não está presente no esquema de entrada
Incluir restrições de não nulo	Incluir ou não as restrições NOT NULL nas instruções CREATE TABLE ou ALTER TABLE ADD COLUMN
Incluir restrições de chave primária	Se deve ou não incluir restrições de chave primária na instrução de criação
Tamanho máximo do lote	O número máximo de FlowFiles que pode ser processado em uma única execução para uma determinada tabela.
Modificar estratégia de chave primária	A estratégia a ser usada quando o esquema de entrada tiver uma chave primária diferente da chave primária existente. A modificação da chave primária requer a eliminação da chave existente, se houver, e a adição de uma nova.
Record Reader	Record Reader a ser usado para obter o esquema desejado
Sufixo de nome de coluna removido	Por exemplo, para renomear a coluna “foo” para “foo__deleted”, a propriedade pode ser definida como `__deleted`
Nome do esquema	O nome do esquema a ser atualizado
Parâmetros de criação de fluxo	Parâmetros adicionais a serem incluídos na instrução CREATE STREAM. Por exemplo, “APPEND_ONLY=TRUE”
Nome de fluxo	O nome do fluxo
Tempo de expiração do cache de metadados da tabela	O tempo em segundos após o qual a entrada do cache será removida
Nome da tabela	O nome da tabela para atualizar ou criar o fluxo
Estratégia de esquema de tabela	Especifica como obter a definição do esquema/tabela desejado
Parâmetros de criação de fluxo de tabela	Parâmetros a serem incluídos na instrução CREATE STREAM. Por exemplo, “APPEND_ONLY=TRUE”. O fluxo será criado junto com a tabela como sua fonte.
Nome do fluxo de tabela	O nome do fluxo criado junto com a tabela. A fonte do fluxo será a tabela criada.
Tipo de atualização	O tipo de atualização a ser realizada
Usar cache de metadados da tabela	Se você deseja armazenar em cache os metadados da tabela em vez de lê-los diretamente do Snowflake. Aplica-se a [Criar tabela se não existir, Alterar tabela]

Relações¶

Nome	Descrição
failure	O FlowFile de entrada é encaminhado a essa relação se a tabela não puder ser atualizada
success	O FlowFile de entrada é encaminhado a essa relação após a atualização bem-sucedida da tabela