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 |
任务的当前状态: |
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 |
拥有对象的角色类型是 |
使用说明¶
视图的延迟时间最长可达 3 小时。
示例¶
根据 ROOT_TASK_ID 和 GRAPH_VERSION 从特定任务图中检索任务:
SELECT * FROM snowflake.account_usage.task_versions WHERE ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d' AND GRAPH_VERSION = 3;
从 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'