SYSTEM$AUTO_REFRESH_STATUS

Retorna o status de atualização automatizada para uma tabela Iceberg gerenciada externamente.

Sintaxe

SYSTEM$AUTO_REFRESH_STATUS('<table_name>')
Copy

Argumentos

'table_name'

O nome da tabela Iceberg para a qual você deseja recuperar o status de atualização automatizada atual.

O nome inteiro deve ser colocado entre aspas simples, incluindo o banco de dados e o esquema, se estiver usando o nome totalmente qualificado. Se o nome da tabela diferenciar maiúsculas de minúsculas ou incluir caracteres especiais ou espaços, você deverá usar aspas duplas. Coloque as aspas duplas dentro das aspas simples, por exemplo, '"Table_Name"'.

Retornos

A função retorna um objeto JSON contendo os seguintes pares nome/valor:

{
  “executionState”:”<value>”,
  ”invalidExecutionStateReason”:”<value>”
  ”pendingSnapshotCount”:<value>,
  ”oldestSnapshotTime”:<value>,
  ”currentSnapshotId”:”<value>”,
  ”lastSnapshotTime”:”<value>”,
  ”lastUpdatedTime”:<value>
}
Copy

Onde:

“executionState”

Estado de execução atual do canal que o Snowflake usa para automatizar atualizações de metadados para a tabela.

Valores:

  • RUNNING: A atualização automatizada está sendo executada conforme o esperado. Este status não indica se o Snowflake está processando ativamente mensagens de evento para o canal.

  • STALLED: A atualização automática encontrou um erro e está tentando se recuperar.

  • STOPPED: A atualização automática encontrou um erro irrecuperável e será interrompida a menos que você tome outra ação. Para obter mais informações, consulte Recuperação de erros.

”invalidExecutionStateReason”

Mensagem de erro associada a um estado de execução STALLED ou STOPPED.

”pendingSnapshotCount”

Número de instantâneos enfileirados para atualização automatizada.

”oldestSnapshotTime”

Carimbo de data/hora mais antigo entre os instantâneos enfileirados. O Snowflake define o carimbo de data/hora para um instantâneo quando o instantâneo é adicionado à fila.

”currentSnapshotId”

ID do instantâneo atual que o Snowflake está rastreando. Isso representa o instantâneo ao qual os dados da tabela atual correspondem.

”lastSnapshotTime”

Carimbo de data/hora de criação do instantâneo atual de acordo com os metadados Iceberg. Este carimbo de data/hora corresponde a quando o instantâneo atual foi gerado no catálogo externo.

”lastUpdatedTime”

Carimbo de data/hora que indica quando o Snowflake processou com sucesso o instantâneo atual. A diferença entre esse valor e lastSnapshotTime indica a latência entre o momento em que os instantâneos são criados no catálogo externo e o momento em que o Snowflake atualiza com sucesso os metadados da tabela.

Para diminuir a latência, ajuste o parâmetro REFRESH_INTERVAL_SECONDS para integração do catálogo associado à tabela.

Notas de uso

Chamar esta função requer uma função que tenha o privilégio OWNERSHIP na tabela Iceberg.

Exemplos

Recupere o status de atualização automatizada da tabela my_iceberg_table no esquema db1.schema1:

SELECT SYSTEM$AUTO_REFRESH_STATUS('db1.schema1.my_iceberg_table');
Copy