dbt实现BigQuery动态SQL报错：无query属性问题求助

错误根源 #

这个错误是因为你错误访问了run_query函数返回对象的query属性。dbt的run_query返回的是Result对象，而非原始查询句柄，该对象并不包含query属性。你可能是照搬了BigQuery控制台的用法，或者对dbt的返回对象结构理解有误。

正确实现方案 #

1. 提取查询结果的正确方式 #

如果你的动态SQL需要返回数据（比如获取列名、元数据），需通过Result对象的rows或columns属性提取内容，而非query。

示例：动态获取表列并生成查询

{# 定义目标表名 #}
{% set target_table = 'user_data' %}

{# 构造动态查询语句 #}
{% set get_columns_query %}
SELECT column_name 
FROM INFORMATION_SCHEMA.COLUMNS 
WHERE table_name = '{{ target_table }}' 
  AND table_schema = '{{ target.dataset }}'
{% endset %}

{# 执行查询并获取结果 #}
{% set column_results = run_query(get_columns_query) %}

{# 提取列名列表 #}
{% if column_results.rows %}
    {% set column_list = column_results.rows | map(attribute=0) | list %}
{% else %}
    {% set column_list = [] %}
{% endif %}

{# 用提取的列名生成最终查询 #}
SELECT {{ column_list | join(', ') }}
FROM `{{ target.dataset }}.{{ target_table }}`

2. 直接执行DDL/DML动态SQL #

如果你的动态SQL是执行DDL（建表、删表）或DML（插入、更新）操作，直接调用run_query执行即可，无需访问额外属性。

示例：动态创建表

{% set create_table_sql %}
CREATE OR REPLACE TABLE `{{ target.dataset }}.aggregated_user_data` AS
SELECT 
  user_id,
  COUNT(*) AS order_count,
  SUM(amount) AS total_spent
FROM `{{ target.dataset }}.orders`
GROUP BY user_id
{% endset %}

{# 执行动态SQL #}
{{ run_query(create_table_sql) }}

3. 常见错误规避 #

• 禁止使用{{ run_query(query).query }}这类写法，Result对象无query属性
• 拼接动态SQL时，注意BigQuery的标识符需用反引号`包裹，避免语法冲突
• 执行查询后，先判断rows是否存在再提取数据，防止空结果引发报错

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