- Schéma :
Vue SNOWPIPE_STREAMING_FILE_MIGRATION_HISTORY¶
Cette vue Account Usage peut être utilisée pour interroger l’historique des données migrées dans des tables Snowflake à l’aide de Snowpipe Streaming au cours des 365 derniers jours (un an). La vue affiche le nombre de lignes et d’octets migrés et les crédits utilisés pour la migration facturée pour l’ensemble de votre compte Snowflake.
Colonnes¶
Nom de la colonne |
Type de données |
Description |
---|---|---|
START_TIME |
TIMESTAMP_LTZ |
Début de la période (dans le fuseau horaire local) dans laquelle la migration de données a eu lieu. |
END_TIME |
TIMESTAMP_LTZ |
Fin de la période (dans le fuseau horaire local) dans laquelle la migration de données a eu lieu. |
CREDITS_USED |
FLOAT |
Nombre de crédits facturés pour la migration de données de Snowpipe Streaming au cours de la fenêtre entre START_TIME et END_TIME. |
NUM_BYTES_MIGRATED |
NUMBER |
Nombre d’octets migrés pendant la fenêtre allant de START_TIME à END_TIME. |
NUM_ROWS_MIGRATED |
NUMBER |
Nombre de lignes migrées durant la fenêtre allant de START_TIME à END_TIME. |
TABLE_ID |
NUMBER |
Identificateur interne/généré par le système pour la table cible dans laquelle le client Snowpipe Streaming charge les données. |
TABLE_NAME |
TEXT |
Le nom de la table cible dans laquelle le client Snowpipe Streaming charge les données. |
SCHEMA_ID |
NUMBER |
Identifiant interne / généré par le système pour le schéma auquel appartient la vue cible. |
SCHEMA_NAME |
TEXT |
Le nom du schéma auquel appartient la table cible. |
DATABASE_ID |
NUMBER |
Identifiant interne / généré par le système pour la base de données à laquelle appartient la vue cible. |
DATABASE_NAME |
TEXT |
Le nom de la base de données à laquelle appartient la table cible. |
Notes sur l’utilisation¶
La latence pour la vue peut atteindre 12 heures. Notez que la migration des fichiers peut parfois être précédée du clustering ou d’autres opérations DML. La migration ne se produit pas toujours et, par conséquent, l’historique de la migration sera vide même après 12 heures.
Les colonnes NUM_BYTES_MIGRATED et NUM_ROWS_MIGRATED indiquent uniquement le nombre d’octets et de lignes traités au cours du processus de migration. Ces chiffres peuvent ne pas correspondre aux nombres réels de lignes et d’octets insérés par Snowpipe Streaming dans la table car certaines lignes et certains octets sont traités en dehors du processus de migration en raison du clustering ou d’autres opérations DML.
Par exemple, Snowpipe Streaming insère 1 million de lignes et la table a 1 million de lignes, mais la colonne NUM_ROWS_MIGRATED dans la vue de l’historique de la migration n’affiche que 800 000 lignes. En effet, les 200 000 autres lignes sont traitées en dehors du processus de migration.
Exemples¶
Interrogez l’historique des données migrées dans des tables Snowflake à l’aide de Snowpipe Streaming au cours des 365 derniers jours.
SELECT * FROM SNOWFLAKE.ACCOUNT_USAGE.SNOWPIPE_STREAMING_FILE_MIGRATION_HISTORY;
La requête renvoie les résultats suivants.
+-------------------------------+-------------------------------+--------------+--------------------+------------------+----------+-----------------+------------+--------------+---------------+--------------+ | START_TIME | END_TIME | CREDITS_USED | NUM_BYTES_MIGRATED | NUM_ROWS_MIGRATED| TABLE_ID | TABLE_NAME | SCHEMA_ID | SCHEMA_NAME | DATABASE_ID | DATABASE_NAME| |-------------------------------+-------------------------------+--------------+--------------------+------------------+----------+----------------------------------------------------------------------------| |2023-02-08 19:00:00.000 +0000 |2023-02-08 20:00:00.000 +0000 | 0.0000325 | 0 | 0 | 16849926| STREAMING_TABLE | 101351 | SNOW | 3166 |STREAMING | |2023-02-07 19:00:00.000 +0000 |2023-02-07 20:00:00.000 +0000 | 0.000096761 | 7,850 | 39 | 16849926| STREAMING_TABLE | 101351 | SNOW | 3166 |STREAMING | +-------------------------------+-------------------------------+--------------+--------------------+------------------+----------+-----------------+------------+--------------+---------------|--------------+