Schema:

ACCOUNT_USAGE

Ansicht TASK_VERSIONS

Mit dieser Account Usage-Ansicht können Sie die Historie der Aufgabenversionen abrufen. Die zurückgegebenen Zeilen geben die Aufgaben an, die zu einem bestimmten Zeitpunkt einen DAG und dessen Eigenschaften umfassten.

Spalten

Spaltenname

Datentyp

Beschreibung

ROOT_TASK_ID

TEXT

Eindeutiger Bezeichner der Stammaufgabe in einem DAG. Diese ID stimmt mit dem Wert in der ID-Spalte der SHOW TASKS-Ausgabe derselben Aufgabe überein. Stimmt mit der ROOT_TASK_ID in COMPLETE_TASK_GRAPHS und TASK_HISTORY überein.

GRAPH_VERSION

NUMBER

Ganzzahl, die die Version der Aufgabe angibt. Stimmt mit der GRAPH_VERSION in COMPLETE_TASK_GRAPHS überein.

GRAPH_VERSION_CREATED_ON

TIMESTAMP_LTZ

Datum und Uhrzeit, zu der diese Version des Task-Graphen gespeichert wurde.

NAME

TEXT

Name der Aufgabe.

ID

TEXT

Eindeutige Kennung für jede Aufgabe. Beachten Sie, dass beim Neuerstellen einer Aufgabe (mit CREATE OR REPLACE TASK) im Wesentlichen eine neue Aufgabe mit einer neuen ID erstellt wird.

DATABASE_ID

NUMBER

Interner/systemgenerierter Bezeichner der Datenbank, die die Aufgabe enthielt.

DATABASE_NAME

TEXT

Name der Datenbank, in der die Aufgabe gespeichert ist.

SCHEMA_ID

NUMBER

Interner/systemgenerierter Bezeichner des Schemas, das die Aufgabe enthielt.

SCHEMA_NAME

TEXT

Name des Schemas, in dem die Aufgabe gespeichert ist.

OWNER

TEXT

Rolle, die die Aufgabe besitzt (d. h. die die Berechtigung OWNERSHIP für die Aufgabe besitzt)

COMMENT

TEXT

Kommentar zur Aufgabe.

WAREHOUSE_NAME

TEXT

Warehouse, das die erforderlichen Ressourcen zum Ausführen der Aufgabe bereitstellt.

SCHEDULE

TEXT

Zeitplan für die Ausführung der Aufgabe. Zeigt NULL an, wenn kein Zeitplan angegeben ist.

PREDECESSORS

ARRAY

JSON-Array aller im Parameter AFTER für die Aufgabe identifizierten Aufgaben (d. h. Vorgängeraufgaben). Wenn diese Aufgaben erfolgreich zu Ende ausgeführt werden, lösen sie die aktuelle Aufgabe aus. Die einzelnen Aufgabennamen im Array sind vollqualifiziert (d. h. sie enthalten den Namen der Container-Datenbank und den Namen des Schemas). Zeigt ein leeres Array an, wenn die Aufgabe keinen Vorgänger hat.

STATE

TEXT

Aktueller Status der Aufgabe: started oder suspended. NULL für Stammaufgaben (Aufgaben ohne Vorgänger).

DEFINITION

TEXT

SQL-Anweisungen, die ausgeführt werden, wenn die Aufgabe ausgeführt wird.

CONDITION_TEXT

TEXT

Bedingung, die in der WHEN-Klausel für die Aufgabe angegeben ist.

ALLOW_OVERLAPPING_EXECUTION

BOOLEAN

Zeigt bei Stammaufgaben eines DAG den Wert TRUE an, wenn eine überlappende Ausführung des DAG explizit erlaubt ist. Zeigt für untergeordnete Aufgaben in einem DAG den Wert NULL an.

ERROR_INTEGRATION

TEXT

Name der Benachrichtigungsintegration, die für den Zugriff auf Amazon Simple Notification Service (SNS) verwendet wird, um Fehlerbenachrichtigungen für die Aufgabe weiterzuleiten.

LAST_COMMITTED_ON

TIMESTAMP_LTZ

Zeitstempel, wann eine Version der Aufgabe zuletzt festgelegt wurde. Wenn keine Version festgelegt wurde (d. h. wenn die Aufgabe nach ihrer Erstellung nicht fortgesetzt oder manuell ausgeführt wurde), ist der Wert NULL.

LAST_SUSPENDED_ON

TIMESTAMP_LTZ

Zeitstempel, wann die Aufgabe zuletzt angehalten wurde. Wenn die Aufgabe noch nicht angehalten wurde, ist der Wert NULL.

CONFIG

TEXT

Zeigt die Konfiguration der Task-Graph-Ebene an, falls diese für die Stammaufgabe festgelegt wurde, andernfalls wird NULL angezeigt.

Nutzungshinweise

Die Latenz der Ansicht kann bis zu 3 Stunden betragen.

Beispiele

Abrufen der Aufgaben eines bestimmten Aufgaben-DAG anhand von ROOT_TASK_ID und GRAPH_VERSION:

SELECT *
FROM snowflake.account_usage.task_versions
WHERE ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d' AND GRAPH_VERSION = 3;
Copy

Abrufen der Aufgabenausführungen eines bestimmten Aufgaben-DAG und dessen Nachfolgeaufgaben aus „task_history“, mit zusätzlichen Aufgabeninformationen aus „task_versions“.

SELECT
task_history.* rename state AS task_run_state,
task_versions.state AS task_state,
task_versions.graph_version_created_on,
task_versions.warehouse_name,
task_versions.comment,
task_versions.schedule,
task_versions.predecessors,
task_versions.allow_overlapping_execution,
task_versions.error_integration
FROM snowflake.account_usage.task_history
JOIN snowflake.account_usage.task_versions using (root_task_id, graph_version)
WHERE task_history.ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d'
Copy