스키마:

ACCOUNT_USAGE

TASK_VERSIONS 뷰

이 Account Usage 뷰에서는 작업 버전 기록을 검색할 수 있습니다. 반환된 행은 주어진 시간에 DAG 와 그 속성을 구성하는 작업을 나타냅니다.

열 이름

데이터 타입

설명

ROOT_TASK_ID

TEXT

DAG의 루트 작업에 대한 고유 식별자입니다. 이 ID는 동일한 작업에 대한 SHOW TASKS 출력의 ID 열 값과 일치합니다. COMPLETE_TASK_GRAPHSTASK_HISTORY 의 ROOT_TASK_ID와 일치합니다.

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

작업의 현재 상태: started 또는 suspended. 루트 작업의 경우 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을 표시합니다.

사용법 노트

뷰의 지연 시간은 최대 3시간입니다.

ROOT_TASK_ID 및 GRAPH_VERSION을 기반으로 특정 작업 DAG에서 작업을 검색합니다.

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

작업_버전의 추가 작업 정보와 함께 작업_기록에서 특정 작업 DAG와 그 하위 작업에 대한 작업 실행을 검색합니다.

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