for 循环中的 DBT 引用

Question

我的 dbt 项目中有一个子查询列表 [“base”、“table_1”、“table_2”、“table_3”...]。

我想将它们加入到一个共同的列 id 中。

我想通过使用 for 循环宏来避免重复。我的问题是，当我尝试在 {{ref}} 中引用子查询名称 {{sub}} 时，出现语法错误。

这是我正在尝试的代码。

{% set subs = ["table_1", "table_2", "table_3"] %}


SELECT
{% for sub in subs %}
    {{sub}}.* EXCEPT (id),
{% endfor %}
base.*
FROM {{ref('base')}} as base
{% for sub in subs %}
    LEFT JOIN {{ref({{sub}})}} as {{sub}}
    ON {{sub}}.id = base.id
{% endfor %}

我收到语法错误

expected token ':', got '}'

如果我更改为

LEFT JOIN {{ref("'"{{sub}}"'")}} as {{sub}}

我收到此错误

expected token ',', got '{'

最后使用

LEFT JOIN {{ref("{{sub}}") }} 作为{{sub}}

我得到

模型依赖于一个名为“{{sub}}”的节点，但未找到

以下是我读过的一些页面，但找不到解决方案

在 Jinja 宏中使用字符串作为参数在dbt

https://docs.getdbt.com/reference/dbt -jinja-functions/ref

Answer 1

当您使用 ref() 时，您已经位于表达式子句 ({{..}}) 内，因此您不需要添加另一个表达式子句来引用你的潜艇。

{% set subs = ["table_1", "table_2", "table_3"] %}


SELECT
{% for sub in subs %}
    {{sub}}.* EXCEPT (id),
{% endfor %}
base.*
FROM {{ref('base')}} as base
{% for sub in subs %}
    LEFT JOIN {{ ref(sub) }} as {{sub}}
    ON {{sub}}.id = base.id
{% endfor %}

---

但是，如果您的子查询实际上是在同一模型中使用 with sql 子句的子查询，则不需要使用 ref() 因为它们不是 dbt模型。您可以查看文档以更好地理解 ref()

{% set subs = ["table_1", "table_2", "table_3"] %}


SELECT
{% for sub in subs %}
    {{sub}}.* EXCEPT (id),
{% endfor %}
base.*
FROM {{ref('base')}} as base
{% for sub in subs %}
    LEFT JOIN {{ sub }}
    ON {{sub}}.id = base.id
{% endfor %}