Dbt Cloud with Airflow と Snowflake の統合

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 - field_10テストクエリで返される最初の 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

  コピー