Surveillance des tables d’événements et alertes pour les tables dynamiques¶

Définition du niveau de gravité des événements sur capturer¶

Pour configurer l’enregistrement des événements de la table dynamique dans la table des événements, définissez le niveau de gravité des événements que vous souhaitez capturer dans la table des événements. Les événements sont saisis aux niveaux suivants :

• ERROR : actualiser les événements d’échec.

• WARN : échecs d’actualisation des tables dynamiques en amont et événements d’échec d’actualisation.

• INFO : les événements d’actualisation réussis, les échecs d’actualisation des tables dynamiques en amont et les événements d’échec d’actualisation.

Pour définir le niveau, définissez le paramètre LOG_EVENT_LEVEL pour le compte ou l’objet. Vous pouvez définir le niveau pour :

• Tous les objets du compte.

• Tous les objets d’une base de données ou d’un schéma.

• Une table dynamique spécifique.

Par exemple :

• Pour capturer des événements de table dynamique de niveau ERROR pour tous les objets pris en charge dans le compte, exécutez ALTER ACCOUNT SET LOG_EVENT_LEVEL :

  CopyExpand

  ALTER ACCOUNT SET LOG_EVENT_LEVEL = ERROR;
  

  Show lessSee more

  Scroll to top

  Définir LOG_EVENT_LEVEL au niveau du compte s’applique aux événements de journal (type d’enregistrementEVENT) pour les charges de travail prises en charge dans le compte, y compris les tables dynamiques. Il ne remplace pas LOG_LEVEL pour les messages de journalisation des APIs de journalisation. Pour plus d’informations, voir Paramètres.

• Pour capturer des événements de niveau INFO pour tous les objets pris en charge dans la base de données``my_db`` , exécutez ALTERDATABASE …SET LOG_EVENT_LEVEL :

  CopyExpand

  ALTER DATABASE my_db SET LOG_EVENT_LEVEL = INFO;
  

  Show lessSee more

  Scroll to top

  Comme pour la définition du niveau sur le compte, la définition du niveau sur la base de données affecte les événements de journal pour les types d’objets pris en charge dans la base de données.

• Pour capturer des événements de niveau WARN pour la table dynamique``my_dynamic_table``, exécutez ALTER DYNAMIC TABLE … SET LOG_EVENT_LEVEL :

  CopyExpand

  ALTER DYNAMIC TABLE my_dynamic_table SET LOG_EVENT_LEVEL = WARN;
  

  Show lessSee more

  Scroll to top

Paramétrer une alerte en cas de nouvelles données¶

Après avoir défini le niveau de gravité des événements de journalisation, vous pouvez configurer une alerte sur les nouvelles données pour surveiller la table d’événements à la recherche de nouveaux événements indiquant une défaillance dans l’actualisation de la table dynamique. Une alerte sur les nouvelles données est déclenchée lorsque de nouvelles lignes sont insérées dans la table de l’événement et remplissent la condition spécifiée dans l’alerte.

Dans la condition d’alerte, pour effectuer une requête sur les événements de la table dynamique, sélectionnez les lignes où resource_attributes:"snow.executable.type" = 'DYNAMIC_TABLE'. Pour réduire la liste des événements, vous pouvez filtrer sur les colonnes suivantes :

• Pour limiter les résultats aux tables dynamiques d’une base de données spécifique, utilisez resource_attributes:"snow.database.name".

• Pour renvoyer les événements où l’actualisation a échoué en raison d’une erreur avec la table dynamique, utilisez value:state = 'FAILED'.

• Pour renvoyer les événements dans lesquels l’actualisation a échoué en raison d’une erreur avec une table dynamique en amont, utilisez value:state = 'UPSTREAM_FAILURE'.

Pour obtenir des informations sur les valeurs connectées pour un événement de table dynamique, voir Informations journalisées pour les événements de table dynamique.

timestamp > DATEADD('minute', -5, CONVERT_TIMEZONE('UTC', CURRENT_TIMESTAMP()))

Par exemple, l’instruction suivante crée une alerte sur les nouvelles données qui exécute une action lorsque les actualisations échouent pour les tables dynamiques dans la base de données my_db. L’exemple suppose que :

• Votre table d’événements active est la table d’événements par défaut <label-logging_event_table_default> (SNOWFLAKE.TELEMETRY.EVENTS).

• Vous avez mis en place une intégration de notification par webhook pour ce canal Slack.

CREATE ALERT my_alert_on_dt_refreshes
  IF( EXISTS(
    SELECT * FROM SNOWFLAKE.TELEMETRY.EVENT_TABLE
      WHERE resource_attributes:"snow.executable.type" = 'dynamic_table'
        AND resource_attributes:"snow.database.name" = 'my_db'
        AND record:"name" = 'refresh.status'
        AND record:"severity_text" = 'ERROR'
        AND value:"state" = 'FAILED'))
  THEN
    BEGIN
      LET result_str VARCHAR;
      (SELECT ARRAY_TO_STRING(ARRAY_AGG(name)::ARRAY, ',') INTO :result_str
         FROM (
           SELECT resource_attributes:"snow.executable.name"::VARCHAR name
             FROM TABLE(RESULT_SCAN(SNOWFLAKE.ALERT.GET_CONDITION_QUERY_UUID()))
             LIMIT 10
         )
      );
      CALL SYSTEM$SEND_SNOWFLAKE_NOTIFICATION(
        SNOWFLAKE.NOTIFICATION.TEXT_PLAIN(:result_str),
        '{"my_slack_integration": {}}'
      );
    END;

Informations journalisées pour les événements de table dynamique¶

Lorsqu’une table dynamique est rafraîchie, un événement est connecté à la table des événements. Les sections suivantes décrivent la ligne de la table des événements qui représente l’événement :

• Valeurs des colonnes de la table des événements

• Paires de valeurs clés dans la colonne resource_attributes

• Paires de valeurs clés dans la colonne record

Activer les spans de pipeline¶

Pour activer les spans de pipeline pour les actualisations des tables dynamiques, définissez le paramètre TRACE_LEVEL sur ALWAYS au niveau de la base de données ou du schéma :

ALTER SCHEMA my_db.my_schema SET TRACE_LEVEL = 'ALWAYS';

Vous pouvez également définir ce paramètre au niveau de la base de données pour capturer les spans de toutes les tables dynamiques de la base de données :

ALTER DATABASE my_db SET TRACE_LEVEL = 'ALWAYS';

Interroger les données des spans¶

Pour interroger les spans de pipeline pour les actualisations des tables dynamiques, filtrez les lignes où record_type = 'SPAN' et record:"name" = 'table_refresh' :

SELECT
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record_attributes:"snow.dynamic_table.state_reason"::STRING AS state_reason,
    record_attributes:"snow.dynamic_table.data_timestamp"::STRING AS data_timestamp,
    trace:"trace_id"::STRING AS trace_id,
    trace:"span_id"::STRING AS span_id,
    record:"status":"code"::STRING AS status_code
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
  ORDER BY start_timestamp ASC;

Corrélation du pipeline avec les IDs de trace et les liens des spans¶

Une capacité unique de spans est la corrélation au niveau du pipeline. Lorsqu’un cycle d’actualisation comprend des opérations d’actualisation pour plusieurs tables dynamiques, tous les spans résultants partagent le même trace:"trace_id". Cela vous permet de reconstruire l’ensemble des opérations d’actualisation qui se sont produites dans un seul cycle d’actualisation.

Chaque span comprend également un tableau record:"links" qui répertorie l’span_id de chaque dépendance en amont. Par exemple, si DT_B dépend de DT_A, puis l’span_id de DT_A apparaît dans les record:"links" de DT_B.

Le champ record:"status":"code" est``STATUS_CODE_OK`` pour les réussites et les omissions, et``STATUS_CODE_ERROR`` pour les échecs.

Par exemple, pour corréler toutes les opérations d’actualisation de tables dynamiques dans un seul cycle d’actualisation, effectuez une requête pour les spans ayant le même trace_id :

SELECT
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record:"links" AS upstream_links
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
    AND trace:"trace_id" = '<trace_id>'
  ORDER BY start_timestamp;

Tracer une actualisation de pipeline¶

Cette section explique comment utiliser les spans de pipeline pour tracer un cycle d’actualisation de bout en bout : rechercher des spans appropriés, récupérer le pipeline complet et diagnostiquer des défaillances ou des omissions.

DT1 --> DT2 --> DT3 --> DT4

SELECT
    trace:"span_id"::STRING AS span_id,
    trace:"trace_id"::STRING AS trace_id,
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.data_timestamp"::STRING AS data_timestamp,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record_attributes:"snow.dynamic_table.state_reason"::STRING AS state_reason,
    resource_attributes:"snow.query.id"::STRING AS query_id,
    start_timestamp,
    timestamp AS end_timestamp
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
    AND resource_attributes:"snow.database.name" = 'MY_DB'
    AND resource_attributes:"snow.schema.name" = 'MY_SCHEMA'
    AND resource_attributes:"snow.executable.name" = 'DT3'
  ORDER BY start_timestamp DESC
  LIMIT 5;

+----------+------------------+---------+-------------------------+-----------+--------------+--------------------------------------+-------------------------+-------------------------+
| SPAN_ID  | TRACE_ID         | DT_NAME | DATA_TIMESTAMP          | STATE     | STATE_REASON | QUERY_ID                             | START_TIMESTAMP          | END_TIMESTAMP           |
|----------+------------------+---------+-------------------------+-----------+--------------+--------------------------------------+-------------------------+-------------------------|
| a1b2c3d4 | 4f3e2d1c0b9a8877 | DT3     | 2026-02-13T10:00:00.000 | FAILED    | QUERY_FAILURE| 01ba7614-0107-e56c-0000-a995024f304a | 2026-02-13 10:02:01.000 | 2026-02-13 10:02:20.000 |
| e5f6a7b8 | 7a8b9c0d1e2f3344 | DT3     | 2026-02-13T09:55:00.000 | SUCCEEDED | NULL         | 01ba7614-0107-e56c-0000-a995024f2f9b | 2026-02-13 09:57:01.000 | 2026-02-13 09:57:18.000 |
+----------+------------------+---------+-------------------------+-----------+--------------+--------------------------------------+-------------------------+-------------------------+

SELECT
    trace:"span_id"::STRING AS span_id,
    trace:"trace_id"::STRING AS trace_id,
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record_attributes:"snow.dynamic_table.state_reason"::STRING AS state_reason,
    resource_attributes:"snow.query.id"::STRING AS query_id,
    start_timestamp,
    timestamp AS end_timestamp,
    DATEDIFF('second', start_timestamp, timestamp) AS duration_sec,
    record:"links" AS upstream_links
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
    AND trace:"trace_id" = '4f3e2d1c0b9a8877'
  ORDER BY start_timestamp ASC;

+----------+------------------+---------+-----------+-----------------+--------------------------------------+-------------------------+-------------------------+--------------+---------------------------------------------+
| SPAN_ID  | TRACE_ID         | DT_NAME | STATE     | STATE_REASON    | QUERY_ID                             | START_TIMESTAMP          | END_TIMESTAMP           | DURATION_SEC | UPSTREAM_LINKS                              |
|----------+------------------+---------+-----------+-----------------+--------------------------------------+-------------------------+-------------------------+--------------+---------------------------------------------|
| f1e2d3c4 | 4f3e2d1c0b9a8877 | DT1     | SUCCEEDED | NULL            | 01ba7614-0107-e56c-0000-a995024f3001 | 2026-02-13 10:01:00.000 | 2026-02-13 10:01:30.000 |           30 | []                                          |
| b5a6c7d8 | 4f3e2d1c0b9a8877 | DT2     | SUCCEEDED | NULL            | 01ba7614-0107-e56c-0000-a995024f3002 | 2026-02-13 10:01:31.000 | 2026-02-13 10:02:00.000 |           29 | [{"span_id": "f1e2d3c4", ...}]              |
| a1b2c3d4 | 4f3e2d1c0b9a8877 | DT3     | FAILED    | QUERY_FAILURE   | 01ba7614-0107-e56c-0000-a995024f304a | 2026-02-13 10:02:01.000 | 2026-02-13 10:02:20.000 |           19 | [{"span_id": "b5a6c7d8", ...}]              |
| c9d0e1f2 | 4f3e2d1c0b9a8877 | DT4     | SKIPPED   | UPSTREAM_FAILURE| NULL                                 | 2026-02-13 10:02:20.000 | 2026-02-13 10:02:20.000 |            0 | [{"span_id": "a1b2c3d4", ...}]              |
+----------+------------------+---------+-----------+-----------------+--------------------------------------+-------------------------+-------------------------+--------------+---------------------------------------------+

WITH pipeline AS (
  SELECT
    trace:"span_id"::STRING AS span_id,
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record_attributes:"snow.dynamic_table.state_reason"::STRING AS state_reason,
    resource_attributes:"snow.query.id"::STRING AS query_id,
    record:"links" AS upstream_links
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
    AND record_attributes:"snow.dynamic_table.data_timestamp" = '2026-02-13T10:00:00.000'
),
target_links AS (
  SELECT f.value:"span_id"::STRING AS upstream_span_id
  FROM pipeline,
  LATERAL FLATTEN(input => upstream_links) f
  WHERE dt_name = 'DT4'
)
SELECT
  p.dt_name AS upstream_dt,
  p.state AS upstream_state,
  p.state_reason AS upstream_reason,
  p.query_id AS upstream_query_id
FROM target_links tl
JOIN pipeline p ON tl.upstream_span_id = p.span_id;

+-------------+----------------+-----------------+--------------------------------------+
| UPSTREAM_DT | UPSTREAM_STATE | UPSTREAM_REASON | UPSTREAM_QUERY_ID                    |
|-------------+----------------+-----------------+--------------------------------------|
| DT3         | FAILED         | QUERY_FAILURE   | 01ba7614-0107-e56c-0000-a995024f304a |
+-------------+----------------+-----------------+--------------------------------------+

WITH pipeline AS (
  SELECT
    trace:"span_id"::STRING AS span_id,
    resource_attributes:"snow.executable.name"::STRING AS dt_name,
    record_attributes:"snow.dynamic_table.state"::STRING AS state,
    record_attributes:"snow.dynamic_table.state_reason"::STRING AS state_reason,
    record:"links" AS upstream_links
  FROM my_event_table
  WHERE record_type = 'SPAN'
    AND record:"name" = 'table_refresh'
    AND record_attributes:"snow.dynamic_table.data_timestamp" = '2026-02-13T10:00:00.000'
)
SELECT p.dt_name, p.state, p.state_reason
FROM pipeline p,
LATERAL FLATTEN(input => p.upstream_links) f
WHERE f.value:"span_id"::STRING = 'a1b2c3d4';

+---------+---------+-----------------+
| DT_NAME | STATE   | STATE_REASON    |
|---------+---------+-----------------|
| DT4     | SKIPPED | UPSTREAM_FAILURE|
+---------+---------+-----------------+