Schéma :

ACCOUNT_USAGE

Vue SNOWPIPE_STREAMING_CHANNEL_HISTORY

La vue historique des canaux fournit un enregistrement historique des erreurs de pipeline, ce qui permet aux utilisateurs de surveiller les tendances en matière de performance. Cette vue affiche des métriques clés telles que le volume de données traitées, les taux d’erreur et la latence.

Vous pouvez utiliser cette vue Account Usage pour effectuer une requête sur l’historique des erreurs pour un canal spécifique.

Colonnes

Nom de la colonne

Type de données

Description

ACCOUNT_ID

INT

L’ID du compte Snowflake.

CREATED_ON

TIMESTAMP_LTZ

Date et heure de création de l’historique du canal du l’ensemble de lignes.

CHANNEL_ID

INT

L’ID interne, généré par le système, du canal de streaming Snowpipe.

PIPE_ID

INT

L’ID interne de l’objet Snowpipe associé à ce canal de streaming Snowpipe.

END_OFFSET

STRING

Le dernier jeton de décalage traité et inclus dans cet enregistrement historique de canal spécifique.

TABLE_ID

INT

L’ID interne de la table cible pour ce canal de streaming Snowpipe.

TABLE_NAME

STRING

Le nom de la table cible pour ce canal de streaming Snowpipe.

TABLE_SCHEMA_ID

INT

L’ID interne du schéma contenant la table cible.

TABLE_SCHEMA_NAME

STRING

Le nom du schéma contenant la table cible.

TABLE_DATABASE_ID

INT

L’ID interne de la base de données contenant la table cible.

TABLE_DATABASE_NAME

STRING

Le nom de la base de données contenant la table cible.

PIPE_NAME

STRING

Le nom défini par l’utilisateur de l’objet Snowpipe associé à ce canal de streaming Snowpipe.

PIPE_SCHEMA_ID

INT

L’ID interne du schéma contenant l’objet Snowpipe.

PIPE_SCHEMA_NAME

STRING

Le nom du schéma contenant l’objet Snowpipe.

PIPE_DATABASE_ID

INT

L’ID interne de la base de données contenant l’objet Snowpipe.

PIPE_DATABASE_NAME

STRING

Le nom de la base de données contenant l’objet Snowpipe.

LAST_ERROR_OFFSET_UPPER_BOUND

STRING

La limite supérieure de l’intervalle de jetons de décalage du dernier ensemble de lignes ayant rencontré des erreurs au cours de cette période historique.

LAST_ERROR_MESSAGE

STRING

Affiche NULL.

SNOWFLAKE_PROCESSING_LATENCY_MS

NUMBER

La latence moyenne, en millisecondes, observée par le service Snowflake dans le traitement des ensembles de lignes pour ce canal au cours de cette période historique.

ROWS_INSERTED

NUMBER

Le nombre total de lignes insérées correctement par ce canal au cours de cette période historique.

ROWS_PARSED

NUMBER

Le nombre total de lignes analysées (traitées) par le canal au cours de cette période historique.

ROWS_ERROR_COUNT

NUMBER

Le nombre total de lignes qui ont rencontré des erreurs et qui n’ont pas été insérées par ce canal au cours de cette période historique.

Notes sur l’utilisation

  • L’architecture haute performance de streaming Snowpipe ne prend en charge que ON_ERROR=CONTINUE. Les autres options de ON_ERROR ne sont pas prises en charge.