Catégories :: Fonctions de métrique des données

DATA_METRIC_SCHEDULED_TIME (fonction de métrique des données système)¶

Renvoie l’horodatage de l’exécution planifiée d’une DMF ou l’horodatage actuel si la fonction est appelée manuellement.

Vous pouvez utiliser cette DMF pour définir des métriques personnalisées afin de mesurer le niveau d’actualisation de vos données ou de définir des métriques incrémentielles en conjonction avec les DMFs qui existent déjà.

Syntaxe¶

SNOWFLAKE.CORE.DATA_METRIC_SCHEDULED_TIME()

Arguments¶

Aucun.

Renvoie¶

La fonction renvoie une valeur scalaire d’un type de données TIMESTAMP_LTZ.

Notes sur l’utilisation¶

L’appel manuel de cette fonction dans une requête SELECT renvoie la même valeur que la fonction CURRENT_TIMESTAMP.

Exemple¶

Créez une fonction de métrique des données personnalisée pour déterminer le niveau d’actualisation des données d’une table au cours de la dernière heure :

CREATE OR REPLACE DATA METRIC FUNCTION data_freshness_hour(
  ARG_T TABLE (ARG_C TIMESTAMP_LTZ))
  RETURNS NUMBER AS
  'SELECT TIMEDIFF(
     minute,
     MAX(ARG_C),
     SNOWFLAKE.CORE.DATA_METRIC_SCHEDULED_TIME())
   FROM ARG_T';

Appelez manuellement la fonction de métrique des données :

SELECT data_freshness_hour(SELECT last_updated FROM hr.tables.empl_info) < 60;
L’instruction renvoie True si la table n’a pas été mise à jour depuis une heure (60 minutes).

L’instruction renvoie False si la table a été mise à jour il y a plus d’une heure.