Schema:: ORGANIZATION_USAGE

Ansicht TASK_VERSIONS¶

Wichtig

Diese Ansicht ist nur im Organisationskonto verfügbar. Weitere Informationen dazu finden Sie unter Premium-Ansichten im Organisationskonto.

Mit der Organization Usage-Ansicht können Sie den Verlauf der Aufgabenversionen abrufen. Die zurückgegebenen Zeilen geben die Aufgaben an, die zu einem bestimmten Zeitpunkt einen Task-Graphen und dessen Eigenschaften umfassten.

Spalten¶

Spalten auf Organisationsebene

Spaltenname	Datentyp	Beschreibung
ORGANIZATION_NAME	VARCHAR	Name der Organisation.
ACCOUNT_LOCATOR	VARCHAR	Vom System generierter Bezeichner für das Konto.
ACCOUNT_NAME	VARCHAR	Benutzerdefinierter Bezeichner für das Konto.

Zusätzliche 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 ROOT_TASK_ID in Ansicht COMPLETE_TASK_GRAPHS und Ansicht TASK_HISTORY überein.
GRAPH_VERSION	NUMBER	Ganzzahl, die die Version der Aufgabe angibt. Stimmt mit der GRAPH_VERSION in Ansicht 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), Microsoft Azure Event Grid oder Google Pub/Sub 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.
TARGET_COMPLETION_INTERVAL	TEXT	Das Zeitfenster, in dem die Aufgabe ausgeführt werden soll. Wird nur für serverlose Aufgaben verwendet. Optional für serverlose Aufgaben, erforderlich für serverlose ausgelöste Aufgaben.
SCHEDULING_MODE	TEXT	Reserviert für zukünftige Funktionalität. Zeigt UNKNOWN an.

Nutzungshinweise¶

Die Latenzzeit der Ansicht kann bis zu 24 Stunden betragen.

Beispiele¶

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

SELECT *
FROM snowflake.organization_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.organization_usage.task_history
JOIN snowflake.organization_usage.task_versions using (root_task_id, graph_version)
WHERE task_history.ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d'

Copy