Esquema:

ACCOUNT_USAGE

Exibição PIPE_USAGE_HISTORY

Essa exibição do Account Usage pode ser usada para consultar o histórico de dados carregados em tabelas usando o Snowpipe ou o histórico de créditos usados para atualização automática do Iceberg nos últimos 365 dias (1 ano).

A exibição exibe o histórico de dados carregados e créditos faturados para toda a sua conta Snowflake. Você pode usar a coluna pipe_name para filtrar a exibição de um canal específico ou da tabela Iceberg com atualização automática.

Colunas

Nome da coluna

Tipo de dados

Descrição

PIPE_ID

NUMBER

Identificador interno/gerado pelo sistema para o canal utilizado para o carregamento de dados. Exibe NULL se nenhum nome de canal foi especificado na consulta. Cada linha inclui os totais para todos os canais em uso dentro do intervalo de tempo.

PIPE_NAME

TEXT

Nome do canal ou da tabela Iceberg com atualização automática. Exibe NULL para o objeto de canal interno (oculto) usado para atualizar os metadados de uma tabela externa ou de uma tabela Iceberg baseada em Delta.

USAGE_DATE

DATE

A data em que ocorreu a ingestão de dados.

CREDITS_USED

NUMBER

Número de créditos faturados para carregamentos de dados do Snowpipe durante o intervalo START_TIME e END_TIME.

BYTES_INSERTED

FLOAT

Número de bytes carregados durante o intervalo START_TIME e END_TIME.

FILES_INSERTED

VARIANT

Número de arquivos carregados durante o intervalo START_TIME e END_TIME.

Notas de uso

  • A latência da visualização pode ser de até 180 minutos (3 horas).

  • Se você quiser reconciliar os dados dessa exibição com uma exibição correspondente no esquema ORGANIZATION USAGE, você deverá primeiro definir o fuso horário da sessão como UTC. Antes de consultar a exibição do Account Usage, execute o seguinte:

    ALTER SESSION SET TIMEZONE = UTC;
    
    Copy
  • Ocasionalmente, o processo de compactação e manutenção de dados pode consumir créditos do Snowflake. Por exemplo, os resultados retornados podem mostrar que você consumiu créditos com 0 BYTES_INSERTED e 0 FILES_INSERTED. Isto significa que seus dados não estão sendo carregados, mas o processo de compactação e manutenção dos dados consumiu alguns créditos.

  • O Snowflake cobra por notificações de atualização automática em tabelas externas e tabelas de diretório em estágios internos nomeados e estágios externos a uma taxa equivalente à taxa de arquivo do Snowpipe. É possível estimar as cobranças incorridas pelas notificações de atualização automática da tabela externa e da tabela de diretório examinando esta exibição do PIPE_USAGE_HISTORY ou fazendo a consulta da função PIPE_USAGE_HISTORY. Note que os canais de atualização automática serão listados sob um nome de canal NULL. Você também pode visualizar o histórico de notificação de atualização automática de sua tabela externa no nível da tabela/nível de estágio de forma granular, usando a função de tabela AUTO_REFRESH_REGISTRATION_HISTORY do Information Schema.

    Para evitar cobranças por notificações de atualização automática, faça uma atualização manual das tabelas externas e tabelas de diretório. Para tabelas externas, a instrução ALTER EXTERNAL TABLE <nome> REFRESH … pode ser usada para sincronizar manualmente sua tabela externa com o armazenamento externo. Para tabelas de diretório, a instrução ALTER STAGE <nome> REFRESH … pode ser usada para sincronizar manualmente o diretório com o armazenamento externo.

  • Snowflake não cobra taxas de arquivo da Snowpipe pela atualização automatizada do Iceber.

Exemplos

Essa consulta fornece o histórico de uso de um canal chamado my_auto_refresh_pipe a partir de uma data específica:

SELECT
    pipe_id,
    start_time,
    end_time,
    credits_used,
    bytes_inserted,
    files_inserted
  FROM SNOWFLAKE.ACCOUNT_USAGE.PIPE_USAGE_HISTORY
  WHERE pipe_name = 'my_auto_refresh_pipe'
  AND START_TIME >= '2025-04-01';
Copy

Essa consulta exibe os créditos usados para cobranças de atualização automática de uma tabela Iceberg chamada iceberg_glue_table a partir de uma determinada data:

SELECT
    pipe_id,
    start_time,
    end_time,
    credits_used,
  FROM SNOWFLAKE.ACCOUNT_USAGE.PIPE_USAGE_HISTORY
  WHERE pipe_name = 'iceberg_glue_table'
  AND START_TIME >= '2025-04-01';
Copy