| 自定义测试 | tests 目录下 .sql,返回行即失败 |
|---|---|
| 严重级别 | severity: error 或 warn |
| 阈值 | error_if / warn_if 表达式 |
| 范围 | 可针对特定分区过滤 |
自定义测试 SQL
自定义测试 SQL
-- tests/assert_pay_amount_non_negative.sql
select order_id, pay_amount
from {{ ref('dwd_trade_order_detail_di') }}
where pay_amount < 0带阈值与级别
带阈值与级别
-- tests/assert_row_count_not_drop.sql
{{ config(severity='warn', error_if='> 1000', warn_if='> 100') }}
select count(1) as bad_rows
from {{ ref('dwd_trade_order_detail_di') }}
where dt = '2026-10-11' and order_id is null把基数类校验(行数骤降)设为 warn、把键完整性问题设为 error,能避免流水线被轻微波动频繁打断。