如何在dbt项目中重写dbt-external-tables包的Snowflake create_empty_table宏

以下是针对宏重写失效问题的具体解决步骤和修正方案：

1. 确认宏的正确命名 #

dbt适配器专属宏的命名规则为[adapter]__[macro_name]，针对Snowflake，你需要将自定义宏命名为snowflake__create_empty_table，而非snowflake_create_empty_table或直接create_empty_table。原包通过dispatch机制分发到该命名的宏，这是重写生效的核心前提。

2. 修正dispatch配置 #

确保dbt_project.yml中的dispatch配置里，search_order的第一个值是你dbt项目的实际名称（即dbt_project.yml顶部name字段的值），示例如下：

dispatch:
  - macro_namespace: dbt-external-tables
    search_order: ['your-actual-project-name', 'dbt-external-tables']

3. 修正宏的实现代码 #

原Issue中的代码存在未定义变量is_csv的问题，会导致执行报错，同时需要调整字段逗号逻辑避免语法错误。修正后的完整宏代码如下：

{% macro snowflake__create_empty_table(source_node) %}
    {%- set columns = source_node.columns.values() %}
    {%- set is_csv = source_node.external.table_type == 'csv' %}

    create or replace table {{ source(source_node.source_name, source_node.name) }} (
        {%- for column in columns %}
            {%- set column_quoted = adapter.quote(column.name) if column.quote else column.name %}
            {%- set col_expression -%}
                {%- if column.col_expression -%}
                    {{ column.col_expression }}
                {%- else -%}
                    {%- set col_id = 'value:c' ~ loop.index if is_csv else 'value:' ~ column_quoted -%}
                    (case when is_null_value({{ col_id }}) or lower({{ col_id }}) = 'null' then null else {{ col_id }} end)
                {%- endif -%}
            {%- endset %}
            {{ column_quoted }} {{ column.data_type }} as ({{ col_expression }}::{{ column.data_type }})
            {{- ',' if not loop.last -}}
        {% endfor %}
        {%- if columns | length > 0 -%},{%- endif %}
        current_timestamp::timestamp as _dbt_copied_at
    );
{% endmacro %}

4. 宏的放置位置 #

将上述宏文件放在你的dbt项目的macros目录下（比如macros/snowflake/custom_create_empty_table.sql），dbt会自动加载该目录下的所有宏文件。

排查验证步骤 #

• 执行dbt compile --select source:<your-source-name>，查看编译后的SQL是否使用了你自定义的宏逻辑
• 检查dbt日志，确认是否有宏加载或语法错误的提示
• 确认dbt_project.yml中的name字段与dispatch配置中的项目名完全一致

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