Airflow 및 Snowflake 통합을 갖춘 Dbt Cloud

dbt_job_run: 완료된 모든 실행의 상태와 메타데이터를 제공합니다. 이 이벤트에는 모델, 스냅샷, 시드 및 테스트에 대한 데이터가 포함되지 않습니다. 속성은 다음과 같습니다:

• project_name

• environment_name

• run_team

• 실행을 위한 dbt Cloud v2 API 에 나열된 모든 필드입니다.

  project_name 및 environment_name 이외의 모든 속성에는 다음이 추가됩니다. run_

  예시 쿼리:

  -- Get status of all job runs in the past seven days
  select 
      project_name,
      environment_name,
      job_name,
      run_created_at,
      run_run_duration_humanized,
      run_status,
      run_status_humanized,
      run_status_message
  from dbt_job_run
  since 7 days ago

  카피

dbt_resource_run dbt 작업 실행에서 실행되는 모든 리소스에 대한 메타데이터 및 상태를 제공합니다. 리소스에는 모델, 스냅샷, 시드 및 테스트가 포함됩니다. 속성은 다음과 같습니다:

• 의 모든 속성 dbt_job_run

• team (dbt 프로젝트 메타에서 구성)

• alert_failed_test_rows

• failed_test_rows_limit

• slack_mentions

• message

• resource_type

• unique_id

• database_name

• schema_name

• test_column_name

• test_model_name

• test_namespace

• test_parameters

• test_short_name

• alias

• severity

• warn_if

• error_if

• tags

• path

• original_file_path

• meta

• meta_config

  예시 쿼리:

  -- Get status of all resources run in the past day
  -- Status = 'None' means the resource exists in the project but was not executed in a particular run
  select 
      project_name,
      environment_name,
      job_name,
      run_created_at,
      resource_type,
      name,
      status
  from dbt_resource_run
  where status != 'None'
  since 1 day ago
  limit 200

  카피

  -- Get all resources types in the past day
  select 
      uniques(resource_type)
  from dbt_resource_run 
  since 1 day ago

  카피

  -- Get the count of all statuses in the last day
  -- Status = 'None' means the resource exists in the dbt project, but was not executed in a particular run
  select 
      count(*) as total_count
  from dbt_resource_run
  facet
      status
  since 1 day ago

  카피

dbt_failed_test_rows: 실패한 테스트 쿼리 결과의 처음 10개 열과 메타데이터를 제공합니다. 이 이벤트는 dbt 테스트의 메타 구성에 alert_failed_test_rows: true 있는 경우에만 생성됩니다. 속성은 다음과 같습니다:

• 의 모든 속성 dbt_resource_run

• field_1 - 테스트 쿼리에서 반환된 처음 10개 열을 나타내는 field_10

  예시 쿼리:

  select 
      project_name,
      environment_name,
      job_name,
      run_created_at,
      name,
      field_1,
      field_2,
      field_3,
      field_4,
      field_5,
      field_6,
      field_7,
      field_8,
      field_9,
      field_10
  from dbt_failed_test_row
  since 7 days ago

  카피