Schéma :

ACCOUNT_USAGE

Vue SNOWPIPE_STREAMING_CLIENT_HISTORY

Cette vue Account Usage peut être utilisée pour interroger le temps passé à charger des données dans des tables Snowflake à l’aide de Snowpipe Streaming au cours des 365 derniers jours (un an). La vue affiche la quantité de données chargées et l’horodatage des appels du client Snowpipe Streaming pour l’ensemble de votre compte Snowflake.

Colonnes

Nom de la colonne

Type de données

Description

CLIENT_NAME

TEXT

Nom du client d’ingestion Snowpipe Streaming.

SNOWFLAKE_PROVIDED_ID

TEXT

Identificateur interne/généré par le système pour le client d’ingestion Snowpipe Streaming pour le chargement de données.

EVENT_TIMESTAMP

TIMESTAMP_LTZ

Début de la période (dans le fuseau horaire local) dans laquelle le chargement de données a eu lieu.

EVENT_TYPE

TEXT

Type d’événement.

BLOB_SIZE_BYTES

NUMBER

La taille du blob en octets.

Notes sur l’utilisation

  • La latence pour la vue peut atteindre 120 minutes (2 heures).

Exemples

Interroge le temps passé à charger des données dans les tables Snowflake à l’aide de Snowpipe Streaming au cours des 365 derniers jours.

SELECT * FROM SNOWFLAKE.ACCOUNT_USAGE.SNOWPIPE_STREAMING_CLIENT_HISTORY;
Copy

La requête renvoie les résultats suivants.

+----------------+----------------------------+------------------------------+--------------+----------------+
|    CLIENT_NAME |    SNOWFLAKE_PROVIDED_ID   |              EVENT_TIMESTAMP |   EVENT_TYPE | BLOB_SIZE_BYTES|
|----------------+--------------------------- +------------------------------+--------------|----------------|
|      MY_CLIENT |FE0B1xJrBAAL3bAAUz1M9876nMCd| 2023-02-04 02:07:34.000 +0000| BLOB_PERSIST |           1,648|
|      MY_CLIENT |D1CIBBPGGFyprBanMvAA1234V3ss| 2023-02-04 02:15:54.000 +0000| BLOB_PERSIST |           3,120|
+----------------+----------------------------+------------------------------+--------------+----------------+
Copy

Interrogez les crédits horaires consommés par chaque client chargeant des données dans des tables Snowflake à l’aide de Snowpipe Streaming au cours des 365 derniers jours.

SELECT COUNT(DISTINCT event_timestamp) AS client_seconds, date_trunc('hour',event_timestamp) AS event_hour, client_seconds*0.000002777777778 as credits, client_name, snowflake_provided_id
FROM SNOWFLAKE.ACCOUNT_USAGE.SNOWPIPE_STREAMING_CLIENT_HISTORY
GROUP BY event_hour, client_name, snowflake_provided_id;
Copy

Notez qu’il peut y avoir plusieurs événements par seconde. Les crédits ne sont consommés qu’en fonction du temps réel passé, et non en fonction du nombre d’événements.

Langage: Français