- Schéma :
Vue PIPE_USAGE_HISTORY¶
Cette vue Account Usage peut être utilisée pour interroger l’historique des données chargées dans les tables à l’aide de Snowpipe ou l’historique des crédits utilisés pour l”actualisation automatiqueIceberg au cours des 365 derniers jours (1 an).
La vue affiche l’historique des données chargées et des crédits facturés pour l’ensemble de votre compte Snowflake. Vous pouvez utiliser la colonne pipe_name
pour filtrer la vue d’un canal spécifique ou d’une table Iceberg avec actualisation automatique.
Colonnes¶
Nom de la colonne |
Type de données |
Description |
---|---|---|
PIPE_ID |
NUMBER |
Identifiant interne / généré par le système pour le canal utilisé pour le chargement de données. Affiche NULL si aucun nom de canal n’a été spécifié dans la requête. Chaque rangée comprend les totaux de tous les canaux utilisés dans l’intervalle de temps. |
PIPE_NAME |
TEXT |
Nom du canal ou de la table Iceberg avec actualisation automatique. Affiche NULL pour l’objet canal interne (caché) utilisé pour actualiser les métadonnées d’une table externe ou d’une table Iceberg basée sur Delta. |
USAGE_DATE |
DATE |
Date à laquelle l’ingestion des données a eu lieu. |
CREDITS_USED |
NUMBER |
Nombre de crédits facturés pour le chargement de données Snowpipe au cours de la fenêtre entre START_TIME et END_TIME. |
BYTES_INSERTED |
FLOAT |
Nombre d’octets chargés au cours de la fenêtre entre START_TIME et END_TIME. |
FILES_INSERTED |
VARIANT |
Nombre de fichiers chargés pendant la fenêtre comprise entre START_TIME et END_TIME. |
Notes sur l’utilisation¶
La latence pour la vue peut atteindre 180 minutes (3 heures).
Si vous souhaitez rapprocher les données de cette vue avec une vue correspondante dans le schéma ORGANIZATION USAGE, vous devez d’abord définir le fuseau horaire de la session sur UTC. Avant d’interroger la vue Account Usage, exécutez ce qui suit :
ALTER SESSION SET TIMEZONE = UTC;
Occasionnellement, le processus de compactage et de maintenance des données peut consommer des crédits Snowflake. Par exemple, les résultats renvoyés peuvent montrer que vous avez consommé des crédits avec 0 BYTES_INSERTED et 0 FILES_INSERTED. Cela signifie que vos données ne sont pas chargées, mais que le processus de compactage et de maintenance des données a consommé des crédits.
Snowflake facture les notifications d’actualisation automatique dans les tables externes et les tables de répertoire sur les zones de préparation internes nommées et les zones de préparation externes à un taux équivalent à celui des fichiers de Snowpipe. Vous pouvez estimer les frais encourus par vos notifications d’actualisation automatique des tables externes et des tables de répertoire en examinant cette vue PIPE_USAGE_HISTORY ou en interrogeant la fonction PIPE_USAGE_HISTORY. Notez que les canaux d’actualisation automatique seront répertoriés sous un nom de canal NULL. Vous pouvez également consulter l’historique des notifications d’actualisation automatique de votre table externe au niveau de la granularité de la table/de la zone de préparation en utilisant la page AUTO_REFRESH_REGISTRATION_HISTORY de la fonction de table d’Information Schema.
Pour éviter les frais liés aux notifications d’actualisation automatique, procédez à une actualisation manuelle des tables externes et des tables de répertoire. Pour les tables externes, l’instruction ALTER EXTERNAL TABLE <nom> REFRESH … peut être utilisée pour synchroniser manuellement votre table externe avec le stockage externe. Pour les tables de répertoire, l’instruction ALTER STAGE <nom> REFRESH … peut être utilisée pour synchroniser manuellement le répertoire avec le stockage externe.
Snowflake ne facture pas de frais de fichiers Snowpipe pour l”actualisation automatique Iceberg.
Exemples¶
Cette requête fournit l’historique de l’utilisation d’un canal nommé my_auto_refresh_pipe
à partir d’une date donnée :
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';
Cette requête affiche les crédits utilisés pour les frais d’actualisation automatiques d’une table Iceberg nommée iceberg_glue_table
à partir d’une date donnée :
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';