Überwachung von Ereignistabellen und Warnmeldungen für dynamische Tabellen

Unter diesem Thema wird beschrieben, wie Sie eine Ereignistabelle abfragen, die Informationen über Ihren Aktualisierungsstatus liefert, und wie Sie Benachrichtigungen über neue Daten in einer Ereignistabelle einrichten.

Ereignistabelle zur Überwachung von Aktualisierungen abfragen

Wenn eine dynamische Tabelle aktualisiert wird, können Sie Snowflake so konfigurieren, dass ein Ereignis aufgezeichnet wird, das Informationen über den Status der Aktualisierungsoperation liefert. Das Ereignis wird in der aktiven Ereignistabelle aufgezeichnet, die mit der dynamischen Tabelle verbunden ist.

Nehmen Sie zum Beispiel an, dass Sie eine Ereignistabelle mit einer Datenbank verknüpft haben. Wenn eine dynamische Tabelle in dieser Datenbank aktualisiert wird, zeichnet Snowflake ein Ereignis in dieser Ereignistabelle auf.

Sie können die in dieser aktiven Ereignistabelle protokollierten Ereignisse abfragen, um die Aktualisierung Ihrer dynamischen Tabellen zu überwachen.

Um beispielsweise den Zeitstempel, den Namen der dynamischen Tabelle, die Abfrage-ID und die Fehlermeldung bei Fehlern mit dynamischen Tabellen in der Datenbank my_db zu erhalten, gehen Sie wie folgt vor:

SELECT
    timestamp,
    resource_attributes:"snow.executable.name"::VARCHAR AS dt_name,
    resource_attributes:"snow.query.id"::VARCHAR AS query_id,
    value:message::VARCHAR AS error
  FROM my_event_table
  WHERE
    resource_attributes:"snow.executable.type" = 'DYNAMIC_TABLE' AND
    resource_attributes:"snow.database.name" = 'MY_DB' AND
    value:state = 'FAILED'
  ORDER BY timestamp DESC;
Copy
+-------------------------+------------------+--------------------------------------+---------------------------------------------------------------------------------+
| TIMESTAMP               | DT_NAME          | QUERY_ID                             | ERROR                                                                           |
|-------------------------+------------------+--------------------------------------+---------------------------------------------------------------------------------|
| 2025-02-17 21:40:45.444 | MY_DYNAMIC_TABLE | 01ba7614-0107-e56c-0000-a995024f304a | SQL compilation error:                                                          |
|                         |                  |                                      | Failure during expansion of view 'MY_DYNAMIC_TABLE': SQL compilation error:     |
|                         |                  |                                      | Object 'MY_DB.MY_SCHEMA.MY_BASE_TABLE' does not exist or not authorized.        |
+-------------------------+------------------+--------------------------------------+---------------------------------------------------------------------------------+

Im folgenden Beispiel werden alle Spalten für Upstream-Fehler mit dynamischen Tabellen im Schema my_schema abgerufen:

SELECT *
  FROM my_event_table
  WHERE
    resource_attributes:"snow.executable.type" = 'DYNAMIC_TABLE' AND
    resource_attributes:"snow.schema.name" = 'MY_SCHEMA' AND
    value:state = 'UPSTREAM_FAILURE'
  ORDER BY timestamp DESC;
Copy
+-------------------------+-----------------+-------------------------+-------+----------+-------------------------------------------------+-------+------------------+-------------+-----------------------------+-------------------+-------------------------------+-----------+
| TIMESTAMP               | START_TIMESTAMP | OBSERVED_TIMESTAMP      | TRACE | RESOURCE | RESOURCE_ATTRIBUTES                             | SCOPE | SCOPE_ATTRIBUTES | RECORD_TYPE | RECORD                      | RECORD_ATTRIBUTES | VALUE                         | EXEMPLARS |
|-------------------------+-----------------+-------------------------+-------+----------+-------------------------------------------------+-------+------------------+-------------+-----------------------------+-------------------+-------------------------------+-----------|
| 2025-02-17 21:40:45.486 | NULL            | 2025-02-17 21:40:45.486 | NULL  | NULL     | {                                               | NULL  | NULL             | EVENT       | {                           | NULL              | {                             | NULL      |
|                         |                 |                         |       |          |   "snow.database.id": 49,                       |       |                  |             |   "name": "refresh.status", |                   |   "state": "UPSTREAM_FAILURE" |           |
|                         |                 |                         |       |          |   "snow.database.name": "MY_DB",                |       |                  |             |   "severity_text": "WARN"   |                   | }                             |           |
|                         |                 |                         |       |          |   "snow.executable.id": 487426,                 |       |                  |             | }                           |                   |                               |           |
|                         |                 |                         |       |          |   "snow.executable.name": "MY_DYNAMIC_TABLE_2", |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.executable.type": "DYNAMIC_TABLE",      |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.owner.id": 2601,                        |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.owner.name": "DATA_ADMIN",              |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.owner.type": "ROLE",                    |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.schema.id": 411,                        |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          |   "snow.schema.name": "MY_SCHEMA"               |       |                  |             |                             |                   |                               |           |
|                         |                 |                         |       |          | }                                               |       |                  |             |                             |                   |                               |           |
+-------------------------+-----------------+-------------------------+-------+----------+-------------------------------------------------+-------+------------------+-------------+-----------------------------+-------------------+-------------------------------+-----------+

Informationen über die Rolle, die Sie für die Abfrage der Ereignistabelle verwenden müssen, und die Bedingungen, die Sie zum Filtern der Ergebnisse verwenden können, finden Sie unter Benachrichtigung über neue Daten einrichten.

Benachrichtigungen für neue Daten einrichten, um Aktualisierungen zu überwachen

Wie bereits erwähnt, wird bei der Aktualisierung einer dynamischen Tabelle ein Ereignis in der Ereignistabelle protokolliert, um anzuzeigen, ob die Aktualisierung erfolgreich war oder nicht. Sie können eine Benachrichtigung über neue Daten einrichten, um die Ereignistabelle zu überwachen. Sie können die Benachrichtigung so konfigurieren, dass eine Benachrichtigung gesendet wird, wenn eine Aktualisierung fehlschlägt.

In den nächsten Abschnitten erfahren Sie, wie Sie die Ereignisprotokollierung einrichten, um die Ereignisse zu erfassen, wie Sie die Benachrichtigung einrichten und wie Sie die in der Ereignistabelle aufgezeichneten Ereignisse interpretieren:

Bemerkung

Die Protokollierung von Ereignissen für dynamische Tabellen ist mit Kosten verbunden. Siehe Kosten der Telemetriedatenerfassung.

Schweregrad der zu erfassenden Ereignisse festlegen

Bemerkung

Wenn Sie den Schweregrad nicht festlegen, werden keine Ereignisse erfasst.

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 die Ebene festzulegen, stellen Sie den Parameter LOG_LEVEL für das Konto oder Objekt ein. Sie können die Ebene festlegen für:

  • Alle Objekte im Konto

  • Alle Objekte in einer Datenbank oder einem Schema

  • Eine bestimmte dynamische Tabelle

Beispiel:

  • Um Ereignisse und Meldungen auf ERROR-Ebene für alle Objekte des Kontos zu erfassen, führen Sie ALTER ACCOUNT SET LOG_LEVEL aus:

    ALTER ACCOUNT SET LOG_LEVEL = ERROR;
    Copy

    Beachten Sie, dass diese Ebene alle Arten von Objekten im Konto betrifft, einschließlich UDFs, gespeicherte Prozeduren, dynamische Tabellen und Aufgaben.

  • Um Ereignisse und Meldungen auf INFO-Ebene für alle Objekte in der Datenbank my_db zu erfassen, führen Sie ALTER DATABASE … SET LOG_LEVEL aus:

    ALTER DATABASE my_db SET LOG_LEVEL = INFO;
    Copy

    Ähnlich wie bei der Einstellung der Ebene für das Konto wirkt sich die Einstellung der Ebene für die Datenbank auf alle Arten von Objekten in der Datenbank aus, einschließlich UDFs, gespeicherte Prozeduren, dynamische Tabellen und Aufgaben.

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

    ALTER DYNAMIC TABLE my_dynamic_table SET LOG_LEVEL = WARN;
    Copy

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.

Bemerkung

Um die Benachrichtigung über neue Daten zu erstellen, müssen Sie eine Rolle verwenden, die über die erforderlichen Berechtigungen zur Abfrage der Ereignistabelle verfügt.

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.

Die folgende Anweisung erstellt beispielsweise eine Benachrichtigung über neue Daten, die eine Aktion ausführt, wenn Aktualisierungen für dynamische Tabellen in der Datenbank my_db fehlschlagen. Das Beispiel geht davon aus, dass:

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_attributes:"event.name" = 'refresh.status'
        AND record:"severity_text" = 'ERROR'
        AND value:"state" = 'FAILED'))
  THEN
    BEGIN
      LET result_str VARCHAR;
      (SELECT ARRAY_TO_STRING(ARRAY_ARG(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;
Copy

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

Wenn eine dynamische Tabelle aktualisiert wird, wird eine Zeile mit den folgenden Werten in die Ereignistabelle eingefügt.

Bemerkung

Wenn eine Spalte unten nicht aufgeführt ist, ist der Spaltenwert für das Ereignis NULL.

Spalte

Datentyp

Beschreibung

timestamp

TIMESTAMP_NTZ

UTC-Zeitstempel für den Zeitpunkt, an dem das Ereignis erstellt wurde.

observed_timestamp

TIMESTAMP_NTZ

UTC-Zeit, die für Protokolle verwendet wird. Derzeit ist dies derselbe Wert, der in der Spalte timestamp steht.

resource_attributes

OBJECT

Attribute, die die aktualisierte dynamische Tabelle identifizieren.

record_type

STRING

Der Ereignistyp, der EVENT für Aktualisierungen von dynamischen Tabellen ist.

record

OBJECT

Details über den Status der Aktualisierung der dynamischen Tabelle.

value

VARIANT

Der Status der Aktualisierung der dynamischen Tabelle und, falls die Aktualisierung fehlgeschlagen ist, die Fehlermeldung für den Fehler.

Schlüssel-Wert-Paare in der Spalte resource_attributes

Die Spalte resource_attributes enthält einen Wert OBJECT mit den folgenden Schlüssel-Wert-Paaren:

Attributname

Attributtyp

Beschreibung

Beispiel

snow.database.id

INTEGER

Der interne/systemgenerierte Bezeichner der Datenbank, die die dynamische Tabelle enthält.

12345

snow.database.name

VARCHAR

Der Name der Datenbank, die die dynamische Tabelle enthält.

MY_DATABASE

snow.executable.id

INTEGER

Der interne/systemgenerierte Bezeichner der dynamischen Tabelle, die aktualisiert wurde.

12345

snow.executable.name

VARCHAR

Der Name der dynamischen Tabelle, die aktualisiert wurde.

MY_DYNAMIC_TABLE

snow.executable.type

VARCHAR

Der Typ des Objekts. Der Wert ist DYNAMIC_TABLE für Ereignisse in dynamischen Tabellen.

DYNAMIC_TABLE

snow.owner.id

INTEGER

Der interne/systemgenerierte Bezeichner der Rolle mit der Berechtigung OWNERSHIP für die dynamische Tabelle.

12345

snow.owner.name

VARCHAR

Der Name der Rolle mit der Berechtigung OWNERSHIP für die dynamische Tabelle.

MY_ROLE

snow.owner.type

VARCHAR

Der Typ der Rolle, die Eigentümer des Objekts ist, zum Beispiel ROLE. . Wenn eine Snowflake Native App Eigentümer des Objekts ist, ist der Wert APPLICATION. . Wenn Sie das Objekt löschen, gibt Snowflake den Wert NULL zurück, da ein gelöschtes Objekt keine Eigentümerrolle hat.

ROLE

snow.query.id

VARCHAR

ID der Abfrage, mit der die dynamische Tabelle aktualisiert wurde.

01ba7614-0107-e56c-0000-a995024f304a

snow.schema.id

INTEGER

Der interne/systemgenerierte Bezeichner des Schemas, das die dynamische Tabelle enthält.

12345

snow.schema.name

VARCHAR

Der Name des Schemas, das die dynamische Tabelle enthält.

MY_SCHEMA

snow.warehouse.id

INTEGER

Der interne/systemgenerierte Bezeichner des Warehouse, das zur Aktualisierung der dynamischen Tabelle verwendet wird.

12345

snow.warehouse.name

VARCHAR

Der Name des Warehouse, das zur Aktualisierung der dynamischen Tabelle verwendet wird.

MY_WAREHOUSE

Schlüssel-Wert-Paare in der Spalte record

Die Spalte record enthält einen Wert OBJECT mit den folgenden Schlüssel-Wert-Paaren:

Schlüssel

Typ

Beschreibung

Beispiel

name

VARCHAR

Der Name des Ereignisses. Der Wert ist refresh_status für Aktualisierungen dynamischer Tabellen.

refresh_status

severity_text

VARCHAR

Der Schweregrad des Ereignisses, der einen der folgenden Werte annehmen kann:

  • INFO: Die Aktualisierung war erfolgreich.

  • ERROR: Die Aktualisierung ist fehlgeschlagen.

  • WARN: Die Aktualisierung einer vorgelagerten dynamischen Tabelle ist fehlgeschlagen.

INFO

Schlüssel-Wert-Paare in der Spalte value

Die Spalte value enthält einen Wert VARIANT mit den folgenden Schlüssel-Wert-Paaren:

Schlüssel

Typ

Beschreibung

Beispiel

state

VARCHAR

Der Status der Aktualisierung, der die folgenden Werte annehmen kann:

  • SUCCEEDED: Die Aktualisierung war erfolgreich.

  • ERROR: Die Aktualisierung ist fehlgeschlagen.

  • UPSTREAM_FAILURE: Die Aktualisierung ist fehlgeschlagen, weil eine dynamische Tabelle nicht aktualisiert werden konnte, von der diese dynamische Tabelle abhängt.

SUCCEEDED

message

VARCHAR

Wenn der Wert in state ERROR lautet, enthält diese Spalte die Fehlermeldung.

SQL compilation error:\nFailure during expansion of view 'MY_DYNAMIC_TABLE': SQL compilation error:\nObject 'MY_DB.MY_SCHEMA.MY_BASE_TABLE' does not exist or not authorized.
Sprache: Deutsch