Überwachung von Ereignistabellen und Warnmeldungen für dynamische Tabellen¶

Schweregrad der zu erfassenden Ereignisse festlegen¶

Um Ereignisse für dynamische Tabellen einzurichten, die in der Ereignistabelle aufgezeichnet werden sollen, legen Sie den Schweregrad der Ereignisse fest, die in der Ereignistabelle erfasst werden sollen. Ereignisse werden auf den folgenden Ebenen erfasst:

• ERROR: Ereignisse für Aktualisierungsfehler.

• WARN: Fehler bei der Aktualisierung von vorgelagerten dynamischen Tabellen und Ereignisse für Aktualisierungsfehler.

• INFO: Ereignisse für erfolgreiche Aktualisierung, Fehler bei der Aktualisierung von vorgelagerten dynamischen Tabellen und Ereignisse für Aktualisierungsfehler.

Um den Grad einzustellen,legen Sie den LOG_EVENT_LEVEL-Parameter für das Konto oder Objekt fest. Sie können den Grad für Folgendes festlegen:

• Alle Objekte im Konto

• Alle Objekte in einer Datenbank oder einem Schema

• Eine bestimmte dynamische Tabelle

Beispiel:

• Um dynamische Tabellenereignisse auf ERROR-Level für alle unterstützten Objekte im Konto zu erfassen, führen Sie ALTER ACCOUNT SET LOG_EVENT_LEVEL aus:

  CopyExpand

  ALTER ACCOUNT SET LOG_EVENT_LEVEL = ERROR;
  

  Show lessSee more

  Scroll to top

  Das Festlegen von LOG_EVENT_LEVEL auf Account-Ebene gilt für Log-Ereignisse (Record-Typ EVENT) für unterstützte Workloads im Account, einschließlich dynamischer Tabellen. Es ersetzt nicht LOG_LEVEL für Logmeldungen beim Loggen von APIs. Weitere Informationen dazu finden Sie unter Parameter.

• Um INFO-Level-Ereignisse für alle unterstützten Objekte in der Datenbank my_db zu erfassen, führen Sie ALTER DATABASE … SET LOG_EVENT_LEVEL aus:

  CopyExpand

  ALTER DATABASE my_db SET LOG_EVENT_LEVEL = INFO;
  

  Show lessSee more

  Scroll to top

  Ähnlich wie beim Festlegen des Levels auf Account-Ebene wirkt sich das Festlegen des Levels auf Datenbankebene auf Log-Ereignisse für unterstützte Objekttypen in der Datenbank aus.

• Um WARN-Level-Ereignisse für die dynamische Tabelle my_dynamic_table zu erfassen, führen Sie ALTER DYNAMIC … TABLE SET LOG_EVENT_LEVEL aus:

  CopyExpand

  ALTER DYNAMIC TABLE my_dynamic_table SET LOG_EVENT_LEVEL = WARN;
  

  Show lessSee more

  Scroll to top

Benachrichtigung über neue Daten einrichten¶

Nachdem Sie den Schweregrad für Protokollierereignisse festgelegt haben, können Sie eine Benachrichtigung über neue Daten einrichten, um die Ereignistabelle auf neue Ereignisse zu überwachen, die auf einen Fehler bei einer dynamischen Tabellenaktualisierung hinweisen. Eine Benachrichtigung über neue Daten wird ausgelöst, wenn neue Zeilen in die Ereignistabelle eingefügt werden, die die in der Benachrichtigung angegebene Bedingung erfüllen.

Um nach Ereignissen in dynamischen Tabellen abzufragen, wählen Sie in der Bedingung der Benachrichtigung Zeilen aus, in denen resource_attributes:"snow.executable.type" = 'DYNAMIC_TABLE' ist. Um die Liste der Ereignisse einzugrenzen, können Sie nach folgenden Spalten filtern:

• Um die Ergebnisse auf dynamische Tabellen in einer bestimmten Datenbank zu beschränken, verwenden Sie resource_attributes:"snow.database.name".

• Um Ereignisse zurückzugeben, bei denen die Aktualisierung aufgrund eines Fehlers in der dynamischen Tabelle fehlgeschlagen ist, verwenden Sie value:state = 'FAILED'.

• Um Ereignisse zurückzugeben, bei denen die Aktualisierung aufgrund eines Fehlers mit einer vorgelagerten dynamischen Tabelle fehlgeschlagen ist, verwenden Sie value:state = 'UPSTREAM_FAILURE'.

Informationen zu den Werten, die für ein Ereignis in einer dynamischen Tabelle protokolliert werden, finden Sie unter Für Ereignisse in dynamischen Tabellen protokollierte Informationen.

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

Die folgende Anweisung erstellt beispielsweise einen Alert für neue Daten, der eine Aktion ausführt, wenn Aktualisierungen von dynamischen Tabellen in der Datenbank my_db fehlschlagen. Das Beispiel nimmt Folgendes an:

• Ihre aktive Ereignistabelle ist die Standard-Ereignistabelle (SNOWFLAKE.TELEMETRY.EVENTS).

• Sie haben eine Webhook-Benachrichtigungsintegration für diesen Slack-Kanal eingerichtet.

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;

Für Ereignisse in dynamischen Tabellen protokollierte Informationen¶

Wenn eine dynamische Tabelle aktualisiert wird, wird ein Ereignis in der Ereignistabelle protokolliert. Die folgenden Abschnitte beschreiben die Zeile der Ereignistabelle, die das Ereignis darstellt:

• Spaltenwerte der Ereignistabelle

• Schlüssel-Wert-Paare in der Spalte resource_attributes

• Schlüssel-Wert-Paare in der Spalte record

Aktivieren Sie Pipeline-Bereiche (Spans).¶

Um Pipeline-Bereiche (Spans) für Aktualisierungen dynamischer Tabellen zu aktivieren, stellen Sie den TRACE_LEVEL-Parameter auf Datenbank- oder Schemaebene auf ALWAYS:

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

Sie können dies auch auf Datenbankebene einstellen, um Bereiche (Spans) für alle dynamischen Tabellen in der Datenbank zu erfassen:

ALTER DATABASE my_db SET TRACE_LEVEL = 'ALWAYS';

Abfragen von Bereichsdaten¶

Um Pipeline-Spans für Aktualisierungen dynamischer Tabellen abzufragen, filtern Sie nach Zeilen, mit record_type = 'SPAN' und 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;

Pipeline-Korrelation mit Trace-IDs und Bereichslinks¶

Eine einzigartige Fähigkeit von Bereichen (Spans) ist die Korrelation auf Pipeline-Ebene. Wenn ein Aktualisierungszyklus Aktualisierungsoperationen für mehrere dynamische Tabellen umfasst, haben alle resultierenden Bereiche (Spans) dieselbe``trace:“trace_id“``. So können Sie den vollständigen Satz von Aktualisierungsoperationen rekonstruieren, die in einer einzelnen Aktualisierungsoperation ausgeführt wurden.

Jeder Bereich (Span) enthält auch einen record:"links"-Array, der die span_id jeder Upstream-Abhängigkeit auflistet. Beispiel: Wenn DT_B von DT_A abhängt, erscheint die span_id von DT_A in record:"links" von DT_B.

Das record:"status":"code"-Feld ist STATUS_CODE_OK für Erfolge und Überspringen, und STATUS_CODE_ERROR für Fehler.

Um beispielsweise alle Aktualisierungsoperationen dynamischer Tabellen in einem einzigen Aktualisierungszyklus zu korrelieren, fragen Sie nach Bereichen mit derselben 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;

Tracking der Aktualisierung einer Pipeline¶

Dieser Abschnitt zeigt Schritt für Schritt, wie Sie Pipeline-Bereiche nutzen, um einen Aktualisierungszyklus von Anfang bis Ende nachzuvollziehen: vom Auffinden der relevanten Bereiche über das Abrufen der vollständigen Pipeline bis hin zur Diagnose von Fehlern oder übersprungenen Ausführungen.

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|
+---------+---------+-----------------+