SHOW STREAMS¶

Lista os fluxos para os quais você tem privilégios de acesso. O comando pode ser usado para listar fluxos para o banco de dados ou esquema atual/especificado, ou em toda a sua conta.

A saída retorna metadados e propriedades do fluxo, ordenados lexicograficamente pelo nome do banco de dados, esquema e fluxo (ver Saída neste tópico para descrições das colunas de saída). Isso é importante se você deseja filtrar os resultados usando os filtros fornecidos.

Consulte também:: CREATE STREAM , ALTER STREAM , DROP STREAM , DESCRIBE STREAM

Sintaxe¶

SHOW [ TERSE ] STREAMS [ LIKE '<pattern>' ]
                       [ IN { ACCOUNT | DATABASE [ <db_name> ] | [ SCHEMA ] [ <schema_name> ] } ]
                       [ STARTS WITH '<name_string>' ]
                       [ LIMIT <rows> [ FROM '<name_string>' ] ]

Copy

Parâmetros¶

TERSE

Retorna apenas um subconjunto das colunas de saída:

created_on
name
kind (renomeação da coluna type em conjunto completo de colunas)
database_name
schema_name
tableOn (renomeação da coluna table_name em conjunto completo de colunas)

LIKE 'pattern'

Opcionalmente, filtra a saída do comando pelo nome do objeto. O filtro utiliza correspondência de padrão que não diferencia maiúsculas e minúsculas, com suporte para caracteres curinga SQL (% e _).

Por exemplo, os seguintes padrões retornam os mesmos resultados:

... LIKE '%testing%' ...

... LIKE '%TESTING%' ...

. padrão: sem valor (nenhuma filtragem é aplicada à saída).

IN ACCOUNT | [ DATABASE ] db_name | [ SCHEMA ] schema_name

Especifica o escopo do comando, que determina se o comando lista registros apenas para o banco de dados ou esquema atual/especificado ou em toda a sua conta:

A palavra-chave DATABASE ou SCHEMA não é necessária; você pode definir o escopo especificando apenas o banco de dados ou o nome do esquema. Da mesma forma, o banco de dados ou o nome do esquema não é necessário se a sessão tiver um banco de dados em uso atualmente.

Se DATABASE ou SCHEMA for especificado sem um nome e a sessão não tiver atualmente um banco de dados em uso, o parâmetro não terá efeito sobre a saída.
Se SCHEMA for especificado com um nome e a sessão não tiver atualmente um banco de dados em uso, o nome do esquema deverá ser totalmente qualificado com o nome do banco de dados (por exemplo, testdb.testschema).

Padrão: depende se a sessão tem ou não um banco de dados em uso no momento:

Banco de dados: DATABASE é o padrão (ou seja, o comando retorna os objetos nos quais você tem privilégios para visualizar no banco de dados).
Sem banco de dados: ACCOUNT é o padrão (ou seja, o comando retorna os objetos que você tem privilégios de visualização em sua conta).

STARTS WITH 'name_string'

Opcionalmente, filtra a saída do comando com base nos caracteres que aparecem no início do nome do objeto. A cadeia de caracteres deve ser delimitada entre aspas simples e há distinção entre maiúsculas e minúsculas.

Por exemplo, as seguintes cadeias de caracteres retornam resultados diferentes:

... STARTS WITH 'B' ...

... STARTS WITH 'b' ...

. Padrão: sem valor (nenhuma filtragem é aplicada à saída)

LIMIT rows [ FROM 'name_string' ]

Opcionalmente, limita o número máximo de linhas retornadas, ao mesmo tempo em que permite a «paginação» dos resultados. O número real de linhas retornadas pode ser menor que o limite especificado. Por exemplo, o número de objetos existentes é menor que o limite especificado.

A subcláusula opcional FROM 'name_string' serve efetivamente como um “cursor” para os resultados. Isso permite obter o número especificado de linhas seguindo a primeira linha cujo nome do objeto corresponde à cadeia de caracteres especificada:

A cadeia de caracteres deve ser delimitada entre aspas simples e há distinção entre maiúsculas e minúsculas.
A cadeia de caracteres não precisa incluir o nome completo do objeto; também é permitido usar nomes parciais.

Padrão: nenhum valor (nenhum limite é aplicado à saída)

Nota

Para comandos SHOW que oferecem suporte às cláusulas FROM 'name_string' e STARTS WITH 'name_string', você pode combinar ambas as cláusulas na mesma instrução. No entanto, ambas as condições devem ser cumpridas ou elas se cancelam mutuamente e nenhum resultado é retornado.

Além disso, os objetos são devolvidos em ordem lexicográfica por nome, portanto FROM 'name_string' só retorna linhas com um valor lexicográfico maior que as linhas retornadas por STARTS WITH 'name_string'.

Por exemplo:

... STARTS WITH 'A' LIMIT ... FROM 'B' não retornaria nenhum resultado.
... STARTS WITH 'B' LIMIT ... FROM 'A' não retornaria nenhum resultado.
... STARTS WITH 'A' LIMIT ... FROM 'AB' retornariam resultados (se alguma linha corresponder às cadeias de caracteres de entrada).

Notas de uso¶

O comando não precisa de um warehouse em funcionamento para ser executado.
O valor de LIMIT rows não pode exceder 10000. Se LIMIT rows for omitido, o comando resulta em um erro se o conjunto de resultados for maior que 10.000 linhas.

Para visualizar os resultados para os quais existem mais de 10.000 registros, incluir LIMIT rows ou consultar a exibição correspondente no Snowflake Information Schema.

Para pós-processar a saída deste comando, você pode usar a função RESULT_SCAN, que trata a saída como uma tabela que pode ser consultada.

Saída¶

O comando de saída fornece propriedades do fluxo e metadados nas seguintes colunas:

Coluna	Descrição
`created_on`	Data e hora em que o fluxo foi criado.
`name`	Nome do fluxo.
`database_name`	Banco de dados do esquema do fluxo.
`schema_name`	Esquema do fluxo.
`owner`	Função proprietária do fluxo.
`comment`	Comentário para o fluxo.
`table_name`	Tabela cujas atualizações DML são rastreadas pelo fluxo.
`source_type`	Objeto de origem para o fluxo: tabela, visualização, tabela de diretório ou tabela externa.
`base_tables`	Tabelas subjacentes para a visualização. Esta coluna se aplica apenas aos fluxos em exibições.
`type`	Tipo do fluxo; atualmente somente DELTA.
`stale`	Indica se o fluxo foi lido pela última vez antes da hora `stale_after` (consulte abaixo). Se este for `TRUE`, o fluxo pode estar obsoleto. Quando um fluxo está obsoleto, ele não pode ser lido. Recriar o fluxo para retomar a leitura a partir dele. Para evitar que um fluxo se torne obsoleto, consuma o fluxo antes de `stale_after`.
`mode`	Exibe `APPEND_ONLY` se o fluxo for um fluxo apenas para anexação. . Exibe `INSERT_ONLY` se o fluxo só retorna informações para linhas inseridas; atualmente se aplica apenas a fluxos em tabelas externas. . Para fluxos em tabelas, a coluna exibe `DEFAULT`.
`stale_after`	Carimbo de data/hora em que o fluxo se tornou obsoleto ou pode se tornar obsoleto se não for consumido. . . O valor é calculado pela soma do período de retenção da tabela de origem (ou seja, o maior dos parâmetros DATA_RETENTION_TIME_IN_DAYS ou MAX_DATA_EXTENSION_TIME_IN_DAYS definidos) à última vez que o fluxo foi lido. Se o período de retenção de dados for definido no nível do esquema ou do banco de dados, a função atual deverá ter acesso ao esquema ou ao banco de dados para executar esse cálculo. . . Esse tempo pode ser impreciso em alguns casos: . - Pode transcorrer algum tempo entre o momento em que o fluxo é permitido para se tornar obsoleto e o momento em que os dados subjacentes são realmente descartados. Durante este período, `stale_after` estará no passado, mas a leitura do fluxo pode ser bem sucedida. A duração deste período está sujeita a mudanças, portanto, você não deve depender dele. . - Se os parâmetros que afetam a retenção da tabela forem aumentados, os fluxos que já estão obsoletos permanecerão obsoletos, mas a hora `stale_after` pode estar no futuro.
`invalid_reason`	Motivo pelo qual o fluxo não pode ser consultado com sucesso. Essa coluna oferece suporte a funcionalidades futuras. Atualmente, o único valor retornado é `N/A`.
`owner_role_type`	O tipo de função que possui o objeto, `ROLE` ou `DATABASE_ROLE`. . Se um Snowflake Native App possuir o objeto, o valor será `APPLICATION`. . Snowflake retornará NULL se você excluir o objeto porque um objeto excluído não tem função de proprietário.

Para obter mais informações sobre as propriedades que podem ser especificadas para um fluxo, consulte CREATE STREAM.

Exemplos¶

Mostrar todos os fluxos cujo nome começa com line que você tem privilégios para ver no esquema tpch.public:

SHOW STREAMS LIKE 'line%' IN tpch.public;

Copy