dbt Cloudでaudit_helperを使用し2つのテーブルが完全一致するか試してみた

packages:
  - package: dbt-labs/audit_helper
    version: 0.12.1

-- 比較対象Aのクエリ,今回はORDER_1
-- 対象のソースorモデルをfrom句に
-- 比較したいカラムをselect句に
{% set old_query %}
  select
    order_id ,
    user_id ,
    product_id ,
    quantity ,
    order_date ,
    status
  from {{ source('public', 'ORDER_1') }}
{% endset %}

-- 比較対象Bのクエリ,今回はORDER_2
-- 対象のソースorモデルをfrom句に
-- 比較したいカラムをselect句に
{% set new_query %}
  select
    order_id ,
    user_id ,
    product_id ,
    quantity ,
    order_date ,
    status
  from {{ source('public', 'ORDER_2') }}
{% endset %}

-- primary_key_columns：比較のためにクエリを結合するために使用される主キー列のリスト
-- columns：比較する 2 つのクエリに存在する列
-- sample_limit：各分類（共通、追加、削除など）ごとに取得するサンプルレコードの上限数。デフォルトは20件です
{{ 
  audit_helper.compare_and_classify_query_results(
    old_query, 
    new_query, 
    primary_key_columns=['order_id'],  
    columns=['order_id', 'user_id', 'product_id','quantity', 'order_date', 'status'],
    sample_limit = 200
  )
}}

dbt run --select compare_and_classify_query_results

-- 比較対象Aのクエリ,今回はORDER_1
-- 対象のソースorモデルをfrom句に
-- 比較したいカラムをselect句に
{% set old_query %}
  select
    order_id ,
    user_id ,
    product_id ,
    quantity ,
    order_date ,
    status
  from {{ source('public', 'ORDER_1') }}
{% endset %}

-- 比較対象Bのクエリ,今回はORDER_3
-- 対象のソースorモデルをfrom句に
-- 比較したいカラムをselect句に
{% set new_query %}
  select
    order_id ,
    user_id ,
    product_id ,
    quantity ,
    order_date ,
    status
  from {{ source('public', 'ORDER_3') }}
{% endset %}

-- primary_key_columns：比較のためにクエリを結合するために使用される主キー列のリスト
-- columns：比較する 2 つのクエリに存在する列
-- sample_limit：各分類（共通、追加、削除など）ごとに取得するサンプルレコードの上限数。デフォルトは20件です
{{ 
  audit_helper.compare_and_classify_query_results(
    old_query, 
    new_query, 
    primary_key_columns=['order_id'],  
    columns=['order_id', 'user_id', 'product_id','quantity', 'order_date', 'status'],
    sample_limit = 200
  )
}}

select
    dbt_audit_row_status,
    COUNT(*) AS row_count
from {{ ref("compare_and_classify_query_results_part2") }}
group by dbt_audit_row_status