| 模型 | models/ 下每个 .sql 文件是一个模型,SELECT 即定义 |
|---|---|
| 依赖 | {{ ref('upstream_model') }} 自动推导 DAG |
| 命令 | dbt run / dbt test / dbt build / dbt docs generate |
增量模型示例
增量模型示例
{{ 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_dailydbt 管转换质量,不含调度与告警;生产上通常由 Airflow/DolphinScheduler 调用 dbt 命令并串联上下游。