UpdateSnowflakeTable 2025.10.2.19¶

Pacote¶

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

Descrição¶

Atualiza a definição de uma tabela do 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»: <only for numeric type>, «scale»: <only for numeric type> }, … ], «primaryKeys»: [«<name of first primary key column>», «<name of second primary key column>», …] } Esse processador oferece suporte a operações somente de tabela: criação, alteração e descarte de tabelas.

Tags¶

alterar, colunas, criar, ddl, descartar, versão preliminar, snowflake, tabela, atualizar

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
Estratégia alterar tipo de coluna	A estratégia a ser usada quando a tabela existente tem uma coluna com um tipo diferente do esquema de entrada.
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`. O resultado da aplicação de transformações com base nessa propriedade será tratado de acordo com a configuração da propriedade `Object Name Handling`.
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
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 valores padrão	Se deve ou não incluir valores DEFAULT nas instruções CREATE TABLE ou ALTER TABLE ADD COLUMN
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.
Resolução do identificador do objeto	Controla como os identificadores dos 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.
Record Reader	Record Reader a ser usado para obter o esquema desejado
Sufixo de nome de coluna removido	O sufixo para anexar a uma coluna que foi removida. Por exemplo, para renomear a coluna “foo” como “foo__deleted”, a propriedade pode ser definida como `__deleted`. O valor dessa propriedade se comportará de maneira diferente dependendo do valor da propriedade `Object Name Handling`, ou seja, se `Object Name Handling` estiver definido como `Case Sensitive Name`, o sufixo será anexado como está. Se `Object Name Handling` estiver definido como `SQL Identifier`, o sufixo deverá consistir somente em letras, números, cifrão ($) e caracteres de sublinhado (_). Além disso, ele será anexado diferenciando ou não maiúsculas de minúsculas, dependendo do nome da coluna que está sendo anexado não diferenciar maiúsculas de minúsculas (sem aspas duplas) ou diferenciar (entre aspas duplas).
Nome do esquema	O nome do esquema que contém a tabela
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 a ser atualizada
Estratégia de esquema de tabela	Especifica como obter a definição do esquema/tabela desejado
Tipo de atualização	O tipo de atualização de tabela a ser executada
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

Grava atributos¶

Nome	Descrição
schema.hash	Um hash SHA-256 do esquema final da tabela após todas as atualizações terem sido concluídas. Pode ser usado para fins de detecção de alterações e cache.