架构:

ACCOUNT_USAGE

TASK_VERSIONS 视图

此 Account Usage 视图使您能够检索 任务版本 的历史记录。返回的行指示在给定时间组成 任务图 的任务及其属性。

列名称

数据类型

描述

ROOT_TASK_ID

TEXT

DAG 中根任务的唯一标识符。此 ID 与同一任务的 SHOW TASKS 输出中的 ID 列值匹配。与 COMPLETE_TASK_GRAPHS 中的 ROOT_TASK_ID 和 TASK_HISTORY 匹配。

GRAPH_VERSION

NUMBER

标识任务版本的整数。与 COMPLETE_TASK_GRAPHS 中的 GRAPH_VERSION 匹配。

GRAPH_VERSION_CREATED_ON

TIMESTAMP_LTZ

保存此版本的任务图的日期和时间。

NAME

TEXT

任务的名称。

ID

TEXT

每个任务的唯一标识符。请注意,重新创建任务(使用 CREATE OR REPLACE TASK)实质上会创建一个新任务,该任务具有新的 ID。

DATABASE_ID

NUMBER

已包含任务的内部/系统生成的数据库标识符。

DATABASE_NAME

TEXT

存储任务的数据库的名称。

SCHEMA_ID

NUMBER

已包含任务的内部/系统生成的架构标识符。

SCHEMA_NAME

TEXT

存储任务的架构的名称。

OWNER

TEXT

拥有任务的角色(即,对任务具有 OWNERSHIP 权限)

COMMENT

TEXT

为任务添加注释。

WAREHOUSE_NAME

TEXT

提供任务运行所需资源的仓库。

SCHEDULE

TEXT

任务运行计划。如果未指定计划,则显示 NULL。

PREDECESSORS

ARRAY

任务的 AFTER 参数中标识的任何任务的 JSON 数组(即前置任务)。运行成功完成后,这些任务将触发当前任务。数组中的各个任务名称是完全限定名称(即包括容器数据库名称和架构名称)。如果任务没有前置任务,则显示空数组。

STATE

TEXT

任务的当前状态:startedsuspended。根任务(没有前置任务的任务)为 NULL

DEFINITION

TEXT

任务运行时执行的 SQL 语句。

CONDITION_TEXT

TEXT

在任务的 WHEN 子句中指定的条件。

ALLOW_OVERLAPPING_EXECUTION

BOOLEAN

对于 DAG 中的根任务,如果明确允许 DAG 的重叠执行,则显示 TRUE。对于 DAG 中的子任务,显示 NULL。

ERROR_INTEGRATION

TEXT

用于访问 Amazon Simple Notification Service (SNS) 以中继任务的错误通知的通知集成名称。

LAST_COMMITTED_ON

TIMESTAMP_LTZ

上次设置任务版本时的时间戳。如果未设置版本(即,如果任务在创建后尚未恢复或手动执行),则值为 NULL。

LAST_SUSPENDED_ON

TIMESTAMP_LTZ

上次暂停任务的时间戳。如果任务尚未暂停,则值为 NULL。

CONFIG

TEXT

如果为根任务设置了图形级别配置,则显示图形级别配置,否则显示 NULL。

OWNER_ROLE_TYPE

TEXT

拥有对象的角色类型是 ROLEDATABASE_ROLE. 如果 Snowflake Native App 拥有该对象,则该值为 APPLICATION. 如果您删除该对象,则 Snowflake 会返回 NULL,原因是删除的对象不具有所有者角色。

使用说明

视图的延迟时间最长可达 3 小时。

示例

根据 ROOT_TASK_ID 和 GRAPH_VERSION 从特定任务图中检索任务:

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

从 task_history 中检索特定任务图及其子任务的任务运行,并从 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
语言: 中文