Configuration d’alertes basées sur des données dans Snowflake¶

Introduction¶

Dans certains cas, vous pouvez souhaiter être informé ou prendre des mesures lorsque les données contenues dans Snowflake remplissent certaines conditions. Par exemple, il se peut que vous vouliez recevoir une notification quand :

• L’utilisation du crédit d’entrepôt augmente d’un certain pourcentage de votre quota actuel déterminé.

• La consommation de ressources pour vos pipelines, tâches, vues matérialisées, etc. augmente au-delà d’un certain montant.

• Vos données ne sont pas conformes à une règle de gestion particulière que vous avez mise en place.

Pour ce faire, vous pouvez configurer une alerte Snowflake. Une alerte Snowflake est un objet de niveau schéma qui spécifie :

• Une condition qui déclenche l’alerte (par exemple, la présence de requêtes qui prennent plus d’une seconde pour se terminer).

• L’action à exécuter lorsque la condition est remplie (par exemple, envoyer une notification par e-mail, saisir des données dans un tableau, etc.)

• Quand et à quelle fréquence la condition doit être évaluée (par exemple, toutes les 24 heures, tous les dimanches à minuit, etc.)

Par exemple, supposons que vous souhaitiez envoyer une notification par e-mail lorsque la consommation de crédit dépasse une certaine limite pour un entrepôt. Supposons que vous vouliez vérifier cela toutes les 30 minutes. Vous pouvez créer une alerte avec les propriétés suivantes :

• Condition : la consommation de crédit pour un entrepôt (la somme de la colonne credits_used dans la vue WAREHOUSE_METERING_HISTORY dans le schéma ACCOUNT_USAGE) dépasse une limite spécifiée.

• Action : envoyer un e-mail à l’administrateur.

• Fréquence / horaire : vérifier cette condition toutes les 30 minutes.

Choix de l’entrepôt pour les alertes¶

Une alerte nécessite un entrepôt pour être exécutée. Vous pouvez utiliser le modèle de calcul sans serveur ou un entrepôt virtuel que vous spécifiez.

Compréhension du coût des alertes¶

Les coûts associés à l’exécution d’une alerte pour exécuter du code SQL varient en fonction des ressources de calcul utilisées pour l’alerte :

• Pour les alertes sans serveur, Snowflake facture votre compte en fonction de l’utilisation des ressources de calcul. Les frais sont calculés sur la base de votre utilisation totale des ressources, y compris l’utilisation du service Cloud, mesurée en heures de calcul d’utilisation du crédit. Le coût en heures de calcul varie en fonction de la taille de l’entrepôt et de la durée d’exécution de la requête. Pour plus d’informations, voir Utilisation du crédit sans serveur.

  Pour savoir combien de crédits sont consommés par des alertes, reportez-vous au « Tableau des crédits de fonctionnalité sans serveur » dans la Table de consommation du service Snowflake.

  Pour afficher l’historique d’utilisation des alertes sans serveur, appelez la fonction SERVERLESS_ALERT_HISTORY.

• Pour les alertes qui utilisent un entrepôt virtuel que vous spécifiez, Snowflake facture votre compte pour l’utilisation du crédit en fonction de l’utilisation de l’entrepôt lorsqu’une alerte est en cours. Cette utilisation est similaire à celle de l’entrepôt pour l’exécution des mêmes instructions SQL dans un client ou Snowsight. La facturation à la seconde et la suspension automatique du crédit vous permettent de commencer avec des tailles d’entrepôts plus grandes, puis d’ajuster la taille en fonction de vos charges de travail d’alertes.

Attribution de privilèges pour créer des alertes¶

Afin de créer une alerte, vous devez utiliser un rôle qui dispose des privilèges suivants :

• Le privilège EXECUTEALERT sur le compte.

  Note

  Ce privilège ne peut être accordé que par un utilisateur ayant le rôle ACCOUNTADMIN.

• Un des privilèges suivants :

  • Le privilège EXECUTE MANAGED ALERT sur le compte, si vous créez une alerte sans serveur.

  • Le privilège USAGE sur l’entrepôt utilisé pour exécuter l’alerte, si vous spécifiez un entrepôt virtuel pour l’alerte.

• Les privilèges USAGE et CREATE ALERT sur le schéma dans lequel vous voulez créer l’alerte.

• Le privilège USAGE sur la base de données contenant le schéma.

Pour accorder ces privilèges à un rôle, utilisez la commande GRANT <privilèges>.

Par exemple, supposons que vous souhaitiez créer un rôle personnalisé nommé my_alert_role qui dispose des privilèges nécessaires pour créer une alerte dans le schéma nommé my_schema. Vous voulez que l’alerte utilise l’entrepôt my_warehouse.

Pour ce faire :

1. Demandez à un utilisateur ayant le rôle ACCOUNTADMIN de faire ce qui suit :

   1. Créez le rôle personnalisé.

      Par exemple :

      USE ROLE ACCOUNTADMIN;
      
      CREATE ROLE my_alert_role;
      

      Copy

   2. Accordez le privilège global EXECUTE ALERT à ce rôle personnalisé.

      Par exemple :

      GRANT EXECUTE ALERT ON ACCOUNT TO ROLE my_alert_role;
      

      Copy

   3. Si vous souhaitez créer une alerte sans serveur, accordez le privilège global EXECUTE MANAGED ALERT à ce rôle personnalisé.

      Par exemple :

      GRANT EXECUTE MANAGED ALERT ON ACCOUNT TO ROLE my_alert_role;
      

      Copy

   4. Attribuez le rôle personnalisé à un utilisateur.

      Par exemple :

      GRANT ROLE my_alert_role TO USER my_user;
      

      Copy

2. Demandez aux propriétaires de la base de données, du schéma et de l’entrepôt d’accorder les privilèges nécessaires à la création de l’alerte pour le rôle personnalisé :

   • Le propriétaire du schéma doit accorder les privilèges CREATE ALERT et USAGE sur le schéma :

     GRANT CREATE ALERT ON SCHEMA my_schema TO ROLE my_alert_role;
     GRANT USAGE ON SCHEMA my_schema TO ROLE my_alert_role;
     

     Copy

   • Le propriétaire de la base de données doit accorder le privilège USAGE sur la base de données :

     GRANT USAGE ON DATABASE my_database TO ROLE my_alert_role;
     

     Copy

   • Si vous voulez spécifier un entrepôt pour l’alerte, le propriétaire de cet entrepôt doit accorder le privilège USAGE sur l’entrepôt :

     GRANT USAGE ON WAREHOUSE my_warehouse TO ROLE my_alert_role;
     

     Copy

Création d’une alerte¶

Supposons que chaque fois qu’une ou plusieurs lignes d’une table nommée gauge ont une valeur dans la colonne gauge_value qui dépasse 200, vous voulez insérer l’horodatage actuel dans une table nommée gauge_value_exceeded_history.

Vous pouvez créer une alerte qui :

• Evalue la condition que gauge_value dépasse 200.

• Insère l’horodatage dans gauge_value_exceeded_history si cette condition est évaluée sur true.

Pour créer une alerte nommée my_alert qui effectue cela :

1. Vérifiez que vous utilisez un rôle qui a les privilèges nécessaires pour créer une alerte.

   Si vous n’utilisez pas ce rôle, exécutez la commande USE ROLE pour utiliser ce rôle.

2. Vérifiez que vous utilisez la base de données et le schéma dans lesquels vous prévoyez de créer l’alerte.

   Si vous n’utilisez pas cette base de données et ce schéma, exécutez les commandes USE DATABASE et USE SCHEMA pour utiliser cette base de données et ce schéma.

3. Exécutez la commande CREATE ALERT pour créer l’alerte.

   CREATE OR REPLACE ALERT my_alert
     WAREHOUSE = mywarehouse
     SCHEDULE = '1 minute'
     IF( EXISTS(
       SELECT gauge_value FROM gauge WHERE gauge_value>200))
     THEN
       INSERT INTO gauge_value_exceeded_history VALUES (current_timestamp());
   

   Copy

   Si vous créez une alerte sans serveur, omettez le paramètre WAREHOUSE :

   CREATE OR REPLACE ALERT my_alert
     SCHEDULE = '1 minute'
     IF( EXISTS(
       SELECT gauge_value FROM gauge WHERE gauge_value>200))
     THEN
       INSERT INTO gauge_value_exceeded_history VALUES (current_timestamp());
   

   Copy

   Pour une description complète de la commande CREATE ALERT, reportez-vous à CREATE ALERT.

   Note

   Lorsque vous créez une alerte, celle-ci est suspendue par défaut. Vous devez reprendre l’alerte nouvellement créée pour que l’alerte s’exécute.

4. Reprenez l’alerte en exécutant la commande ALTER ALERT … RESUME. Par exemple :

   ALTER ALERT my_alert RESUME;
   

   Copy

Spécification des horodatages basés sur les planifications d’alerte¶

Dans certains cas, vous pouvez avoir besoin de définir une condition ou une action basée sur le programme d’alerte.

Par exemple, supposons qu’une table possède une colonne d’horodatage qui représente le moment où une ligne a été ajoutée, et que vous souhaitez envoyer une alerte si de nouvelles lignes ont été ajoutées entre la dernière alerte évaluée avec succès et l’alerte programmée actuelle. En d’autres termes, vous voulez évaluer :

<now> - <last_execution_of_the_alert>

Si vous utilisez CURRENT_TIMESTAMP et l’heure prévue de l’alerte pour calculer cette plage de temps. La plage calculée ne tient pas compte de la latence entre l’heure à laquelle l’alerte est prévue et l’heure à laquelle la condition d’alerte est effectivement évaluée.

Au lieu de cela, lorsque vous avez besoin des horodatages de l’alerte programmée actuelle et de la dernière alerte qui a été évaluée avec succès, utilisez les fonctions suivantes :

• SCHEDULED_TIME renvoie l’horodatage représentant la date à laquelle l’alerte actuelle a été programmée.

• LAST_SUCCESSFUL_SCHEDULED_TIME renvoie l’horodatage représentant la date à laquelle la dernière alerte évaluée avec succès a été programmée.

Ces fonctions sont définies dans le schéma SNOWFLAKE.ALERT. Pour appeler ces fonctions, vous devez utiliser un rôle possédnant le SNOWFLAKE.ALERT_VIEWERrôle de la base de données. Pour accorder ce rôle à un autre rôle, utilisez la commande GRANT DATABASE ROLE. Par exemple, pour accorder ce rôle au rôle personnalisé alert_role, exécutez :

GRANT DATABASE ROLE SNOWFLAKE.ALERT_VIEWER TO ROLE alert_role;

L’exemple suivant envoie un message électronique si de nouvelles lignes ont été ajoutées à my_table entre le moment où la dernière alerte évaluée avec succès a été programmée et le moment où l’alerte actuelle a été programmée :

CREATE OR REPLACE ALERT alert_new_rows
  WAREHOUSE = my_warehouse
  SCHEDULE = '1 MINUTE'
  IF (EXISTS (
      SELECT *
      FROM my_table
      WHERE row_timestamp BETWEEN SNOWFLAKE.ALERT.LAST_SUCCESSFUL_SCHEDULED_TIME()
       AND SNOWFLAKE.ALERT.SCHEDULED_TIME()
  ))
  THEN CALL SYSTEM$SEND_EMAIL(...);

Vérification des résultats de l’instruction SQL pour la condition de l’action d’alerte¶

Dans l’action d’une alerte, si vous devez vérifier les résultats de l’instruction SQL pour la condition :

1. Appelez la fonction GET_CONDITION_QUERY_UUID pour obtenir l’ID de la requête pour l’instruction SQL de la condition.

2. Transmettez l’ID de la requête à la fonction RESULT_SCAN pour obtenir les résultats de l’exécution de l’instruction SQL.

Par exemple :

CREATE ALERT my_alert
  WAREHOUSE = my_warehouse
  SCHEDULE = '1 MINUTE'
  IF (EXISTS (
    SELECT * FROM my_source_table))
  THEN
    BEGIN
      LET condition_result_set RESULTSET :=
        (SELECT * FROM TABLE(RESULT_SCAN(SNOWFLAKE.ALERT.GET_CONDITION_QUERY_UUID())));
      ...
    END;

Exécution manuelle des alertes¶

Dans certains cas, il se peut que vous deviez exécuter une alerte manuellement. Par exemple :

• Si vous créez une nouvelle alerte, vous voudrez peut-être vérifier que l’alerte fonctionne comme prévu.

• Il se peut que vous souhaitiez exécuter l’alerte à un point précis de votre pipeline de données. Par exemple, vous pourriez vouloir exécuter l’alerte à la fin de l’appel d’une procédure stockée.

Pour exécuter une alerte manuellement, exécutez la commande EXECUTE ALERT:

EXECUTE ALERT my_alert;

La commande EXECUTE ALERT déclenche manuellement l’exécution unique d’une alerte, indépendamment de la programmation définie pour l’alerte.

Vous pouvez exécuter cette commande de manière interactive. Vous pouvez également exécuter cette commande à partir d’une procédure stockée ou d’un bloc de script Snowflake.

Pour plus de détails sur les privilèges requis pour exécuter cette commande et sur l’effet de cette commande sur les alertes suspendues, en cours d’exécution et programmées, consultez EXECUTE ALERT.

Suspension et reprise d’une alerte¶

Si vous devez empêcher l’exécution temporaire d’une alerte, vous pouvez la suspendre en exécutant la commande ALTER ALERT … SUSPEND. Par exemple :

ALTER ALERT my_alert SUSPEND;

Pour reprendre une alerte suspendue, exécutez la commande ALTER ALERT … RESUME. Par exemple :

ALTER ALERT my_alert RESUME;

Modification d’une alerte¶

Pour modifier les propriétés d’une alerte, exécutez la commande ALTER ALERT. Par exemple :

• Pour changer l’entrepôt de l’alerte nommée my_alert en my_other_warehouse, exécutez :

  ALTER ALERT my_alert SET WAREHOUSE = my_other_warehouse;
  

  Copy

• Pour modifier le programme de l’alerte nommée my_alert afin qu’elle soit évaluée toutes les 2 minutes, exécutez :

  ALTER ALERT my_alert SET SCHEDULE = '2 minutes';
  

  Copy

• Pour modifier la condition de l’alerte nommée my_alert afin d’être alerté si des lignes de la table nommée gauge ont des valeurs supérieures à 300 dans la colonne gauge_value, exécutez :

  ALTER ALERT my_alert MODIFY CONDITION EXISTS (SELECT gauge_value FROM gauge WHERE gauge_value>300);
  

  Copy

• Pour modifier l’action de l’alerte nommée my_alert en CALL my_procedure(), exécutez :

  ALTER ALERT my_alert MODIFY ACTION CALL my_procedure();
  

  Copy

Destruction d’une alerte¶

Pour détruire une alerte, exécutez la commande DROP ALERT. Par exemple :

DROP ALERT my_alert;

Pour supprimer une alerte sans déclencher d’erreur si l’alerte n’existe pas, exécutez :

DROP ALERT IF EXISTS my_alert;

Affichage des détails à propos d’une alerte¶

Pour dresser la liste des alertes créées dans un compte, une base de données ou un schéma, exécutez la commande SHOW ALERTS. Par exemple, pour dresser la liste des alertes qui ont été créées dans le schéma actuel, exécutez la commande suivante :

SHOW ALERTS;

Cette commande dresse la liste des alertes dont vous êtes propriétaire et des alertes pour lesquelles vous disposez du privilège MONITOR ou OPERATE.

Pour voir les détails d’une alerte spécifique, exécutez la commande DESCRIBE ALERT. Par exemple :

DESC ALERT my_alert;

Clonage d’une alerte¶

Vous pouvez cloner une alerte (soit en utilisant CREATE ALERT … CLONE, soit en clonant la base de données ou le schéma contenant l’alerte).

Si vous clonez une alerte sans serveur, vous n’avez pas besoin d’utiliser un rôle doté du privilège global EXECUTE MANAGED ALERT. Toutefois, vous ne pourrez pas reprendre ce signalement tant que le rôle propriétaire de l’alerte n’aura pas obtenu le privilège EXECUTE MANAGED ALERT.

Suivi de l’exécution des alertes¶

Pour surveiller l’exécution des alertes, vous pouvez :

• Vérifier les résultats de l’action qui a été spécifiée pour l’alerte. Par exemple, si l’action a inséré des lignes dans un tableau, vous pouvez vérifier la présence de nouvelles lignes dans le tableau.

• Voir l’historique des exécutions d’alertes en utilisant l’une des méthodes suivantes :

  • La fonction de table ALERT_HISTORY dans le schéma INFORMATION_SCHEMA.

    Par exemple, pour voir les exécutions d’alertes au cours de la dernière heure, exécutez l’instruction suivante :

    SELECT *
    FROM
      TABLE(INFORMATION_SCHEMA.ALERT_HISTORY(
        SCHEDULED_TIME_RANGE_START
          =>dateadd('hour',-1,current_timestamp())))
    ORDER BY SCHEDULED_TIME DESC;
    

    Copy

  • La vue ALERT_HISTORY dans le schéma ACCOUNT_USAGE de la base de données partagée SNOWFLAKE.

Dans l’historique des requêtes, le nom de l’utilisateur qui a exécuté la requête sera SYSTEM. (Les alertes sont exécutées par le service système.)

Vue de l’historique des requêtes d’une alerte sans serveur¶

Pour voir l’historique des requêtes d’une alerte sans serveur, vous devez être le propriétaire de l’alerte ou utiliser un rôle qui dispose du privilège MONITOR ou OPERATE sur l’alerte elle-même. (Cela diffère des alertes utilisant l’un de vos entrepôts, qui nécessitent le privilège MONITOR ou OPERATOR sur l’entrepôt)

Par exemple, supposons que vous souhaitiez utiliser le rôle my_alert_role pour voir l’historique des requêtes de l’alerte my_alert. Si my_alert_role n’est pas le propriétaire de my_alert, vous devez accorder à ce rôle le privilège MONITOR ou OPERATE sur l’alerte :

GRANT MONITOR ON ALERT my_alert TO ROLE my_alert_role;

Une fois ce privilège accordé au rôle, vous pouvez l’utiliser pour voir l’historique des requêtes de l’alerte :

USE ROLE my_alert_role;

SELECT query_text FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY())
  WHERE query_text LIKE '%Some condition%'
    OR query_text LIKE '%Some action%'
  ORDER BY start_time DESC;