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 Task-Graphen 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.
OWNER_ROLE_TYPE	TEXT	Der Typ der Rolle, die Eigentümer des Objekts ist, entweder `ROLE` oder `DATABASE_ROLE`. . Wenn eine Snowflake Native App Eigentümer des Objekts ist, ist der Wert `APPLICATION`. . Wenn Sie das Objekt löschen, gibt Snowflake NULL zurück, da ein gelöschtes Objekt keine Eigentümerrolle hat.

Nutzungshinweise¶

Die Latenz der Ansicht kann bis zu 3 Stunden betragen.

Beispiele¶

Abrufen der Aufgaben eines bestimmten Task-Graphen 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 Task-Graphen 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