Pular para o conteúdo
Lucas Lessa
Voltar para as notícias
SnowflakeGAImpacto: Médio

Monitore seus streams com a nova view STREAMS no Account Usage

A nova view ACCOUNT_USAGE.STREAMS no Snowflake lista propriedades, objetos de origem, modo e validade de todos os streams da conta.

O que mudou

A view STREAMS foi adicionada ao esquema ACCOUNT_USAGE para centralizar metadados sobre todos os streams da sua conta do Snowflake.### Para que serveImagine que você precisa auditar quais streams estão ativos, quais fontes eles monitoram e quais correm risco de expirar. Com essa view, você pode listar rapidamente o inventário de streams para governança, limpeza de objetos órfãos ou análise de dependências. Dá para consultar: o objeto de origem e tabelas base, o modo de operação (append-only, insert-only ou padrão), data de criação e dono, além do momento estimado em que o stream fica obsoleto (stale).### Como usar```sql SELECT stream_catalog, stream_schema, stream_name, source_type, mode, created FROM snowflake.account_usage.streams WHERE deleted IS NULL ORDER BY stream_catalog, stream_schema, stream_name;

1. Seleciona o banco, schema, nome, tipo de origem, modo e data de criação de cada stream.
2. Filtra a consulta na view `snowflake.account_usage.streams` para desconsiderar streams já deletados.
3. Ordena o resultado pelo caminho completo do objeto para facilitar a leitura.

```sql
SELECT stream_catalog, stream_schema, stream_name, table_name, stale_after
FROM snowflake.account_usage.streams
WHERE deleted IS NULL
  AND stale_after < DATEADD('day', -1, CURRENT_TIMESTAMP())
ORDER BY stale_after;
```O que acontece nesse código:
1. Busca metadados de streams ativos incluindo a previsão de validade (`stale_after`).
2. Aplica um filtro para retornar apenas streams cujo prazo de validade expirou há mais de um dia.
3. Ordena a lista pela data em que ficaram obsoletos para identificar candidatos à remoção.### O que retornaCampo | Descrição
--- | ---
STREAM_ID | Identificador interno gerado pelo Snowflake para o stream.
STREAM_NAME | Nome do stream.
STREAM_SCHEMA | Nome do schema que contém o stream.
STREAM_CATALOG | Nome do banco de dados que contém o stream.
OWNER | Nome da role dona do stream.
TABLE_NAME | Nome totalmente qualificado do objeto de origem do stream.
SOURCE_TYPE | Tipo do objeto de origem (Table, View, External Table, Stage).
BASE_TABLES | Tabelas base subjacentes cujas alterações o stream rastreia.
TYPE | Tipo do stream (atualmente apenas DELTA).
MODE | Modo do stream (APPEND_ONLY, INSERT_ONLY ou DEFAULT).
STALE_AFTER | Timestamp em que o stream se torna obsoleto se não for consumido.
DELETED | Data de exclusão do stream, ou NULL se estiver ativo.### Limitações e requisitos- A latência para atualização dos dados na view pode ser de até 2 horas.
- Streams cujas tabelas base são compartilhadas de outra conta possuem suporte limitado na view.
Ver nota oficial do Snowflake

10.35 Release Notes: Sep 24, 2026 - Sep 30, 2026

Resumo e explicação gerados por IA a partir da release note oficial. Em caso de dúvida, a documentação oficial da plataforma prevalece.

Relacionadas