dbt 是什么

dbt 用「SQL 加配置」的方式管理数仓内的转换：models 目录下每个 .sql 文件就是一个模型，文件里写一条 SELECT，其余交给 dbt。模型之间用 ref() 引用上游，dbt 据此自动推导依赖图并按顺序执行，还能顺带跑数据测试、生成文档。它解决的是「一堆 SQL 脚本谁先跑、谁依赖谁」的问题，但不负责调度和告警——生产上仍由外部调度器调用 dbt 命令。

基本信息

增量模型示例

{{ config(materialized='incremental', unique_key='order_id') }}
SELECT order_id, amount, updated_at
FROM {{ ref('ods_orders') }}
{% if is_incremental() %}
WHERE updated_at > (SELECT max(updated_at) FROM {{ this }})
{% endif %}

执行与测试

dbt run --select dwd_orders+      # 该模型及其下游
dbt test --select dwd_orders
dbt build --select +ads_sales_daily   # 上游 + 自身（含测试）
dbt docs generate && dbt docs serve

典型使用场景

• 分层建表：ODS 到 DWD 到 ADS 每层若干模型，依赖由 ref 自动串起
• 增量更新：按 unique_key 合并，避免每天整表重算
• 质量卡口：为模型配置唯一性、非空、取值范围测试，跑完即校验
• 文档沉淀：从模型描述与注释生成数据字典，减少口头约定
• 回归比对：改动模型后按选择器只跑受影响分支，快速验证
• 按标签分组调度：把夜间全量、白天增量用 tag 区分，各自触发
• 源表契约：用 source() 声明上游表并加新鲜度校验，上游延迟时提前失败

选择器读法