如何通过单个DBT模型生成两个带/不带过滤的数据库模型？

要实现单个SQL文件输出两个仅过滤条件不同的DBT模型，核心是用Jinja循环遍历预定义的模型配置，在同一文件中生成多个独立的模型定义，具体示例如下：

基础实现示例 #

创建模型文件models/my_dual_model.sql，内容如下：

{% set model_definitions = [
    {'alias': 'user_data_full', 'filter_condition': '1=1'},
    {'alias': 'user_data_active', 'filter_condition': 'user_status = \'active\''}
] %}

{% for model in model_definitions %}
    {{ config(
        materialized='table',
        alias=model.alias
    ) }}

    SELECT
        user_id,
        username,
        user_status,
        signup_date
    FROM raw.raw_user_data
    WHERE {{ model.filter_condition }}
{% endfor %}

代码说明 #

• 先定义model_definitions列表，每个元素包含目标模型的别名（最终数据库表名）和对应的过滤条件
• 通过Jinja的for循环，为每个配置生成独立的模型：
  • config(alias=model.alias)指定模型的实际名称，确保DBT生成两个不同的表
  • 复用相同的SELECT逻辑，仅替换WHERE子句的过滤条件

更灵活的配置方式 #

如果需要频繁调整模型配置，建议把定义放到dbt_project.yml的变量中，避免修改SQL文件：

在dbt_project.yml中添加变量：

vars:
  dual_user_models:
    - alias: user_data_full
      filter: "1=1"
    - alias: user_data_active
      filter: "user_status = 'active'"

然后修改模型文件models/my_dual_model.sql：

{% for model in var('dual_user_models') %}
    {{ config(
        materialized='table',
        alias=model.alias
    ) }}

    SELECT
        user_id,
        username,
        user_status,
        signup_date
    FROM raw.raw_user_data
    WHERE {{ model.filter }}
{% endfor %}

注意事项 #

• DBT 0.18及以上版本支持单个文件生成多个模型，确保你的版本符合要求
• 若使用增量模型（materialized='incremental'），需要额外处理增量逻辑的兼容性，比如为每个模型单独配置增量策略
• 过滤条件中的字符串要正确转义，避免SQL语法错误
• 运行dbt run时，两个模型会同时被构建，也可以通过dbt run --select user_data_full单独运行其中一个

内容的提问来源于stack exchange，提问作者dwh_dev