如何在dbt Jinja宏的config函数中以{{this}}为参数传入当前模型名

错误原因 #

你当前的写法存在JinJa语法错误：config 本身已经被 {{ }} 包裹，处于JinJa解析上下文内，此时嵌套使用 {{this}} 属于重复标记，dbt无法正常解析该语法。

修复方案 #

直接在宏调用时传递this变量即可，不需要额外加引号或嵌套的模板标记，修改模型文件model/Table1.sql的配置代码如下：

{{ config(post_hook= calculate_test(this)) }}

如果需要使用字符串形式定义post_hook（比如配置多个钩子、混合原生SQL语句的场景），可以使用如下写法：

{{ config(post_hook = "{{ calculate_test(this) }}") }}

可选优化 #

原宏代码缺少运行阶段判断，dbt在项目编译阶段就会执行宏内代码，此时表还未创建会触发报错，可以给宏增加执行阶段判断：

{% macro calculate_test(tableN) %}
    {%- set tableName = tableN -%}
    {% if execute %}
    {% set sql %}
        SELECT 
            COUNT(*) as cnt
        FROM {{ tableName }}
    {% endset %}
    {% set results = run_query(sql) %}
    {# 可在此处添加结果处理逻辑，例如打印行数 #}
    {% do log(tableName ~ " 表行数：" ~ results.columns[0].values()[0], info=True) %}
    {% endif %}
{% endmacro %}

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