dbt调用Snowflake存储过程报跨范围事务修改错误如何解决

• 该报错与你猜测的array_construct函数无关，核心是dbt的事务管理机制和Snowflake存储过程的事务处理产生了冲突。
• dbt执行run_query时会默认开启一个外层事务，若你的存储过程内部包含事务控制逻辑（比如显式的COMMIT/ROLLBACK语句，或是会隐式触发事务提交的DDL操作），就会触发Snowflake的跨事务作用域修改限制，抛出对应错误。
• 你直接在Snowflake控制台执行CALL语句正常，是因为Snowflake控制台默认开启自动提交模式，单条CALL语句独立运行在单独事务中，没有外层事务包裹，不存在作用域冲突。

有三种可落地的解决方法，按需选择即可：

方法1：修改存储过程定义（最推荐，适配性最高） #

在创建存储过程的语句中添加COMMIT ON RETURN TRUE参数，指定存储过程执行完成后自动提交内部产生的事务，不会和外层的dbt事务产生冲突，示例创建语法参考：

CREATE OR REPLACE PROCEDURE MyStoredProcedure(param1 ARRAY, param2 VARCHAR, param3 VARCHAR)
RETURNS VARCHAR
LANGUAGE JAVASCRIPT
COMMIT ON RETURN TRUE -- 新增这一行即可
AS
$$
-- 你的存储过程原有逻辑
$$;

方法2：调整dbt宏逻辑，手动提交外层事务 #

在执行存储过程调用前，先提交dbt默认开启的外层事务，避免作用域冲突，修改后的宏代码如下：

{% macro MyStoredProcedure() %}
    -- 先提交dbt已开启的外层事务
    {% do run_query("COMMIT") %}
    {% set query -%}
        CALL MyStoredProcedure(
           array_construct(array_construct('str_1', 'str_2')),
           'schema_name',
           'table_name');
    {%- endset %}
    {% do run_query(query) %}
{% endmacro %}

方法3：临时修改会话自动提交配置 #

在调用存储过程前开启会话自动提交，执行完成后可按需恢复原有配置，宏代码参考：

{% macro MyStoredProcedure() %}
    -- 开启当前会话自动提交
    {% do run_query("ALTER SESSION SET AUTOCOMMIT = TRUE") %}
    {% set query -%}
        CALL MyStoredProcedure(
           array_construct(array_construct('str_1', 'str_2')),
           'schema_name',
           'table_name');
    {%- endset %}
    {% do run_query(query) %}
    -- 可选：恢复默认自动提交配置
    {% do run_query("ALTER SESSION SET AUTOCOMMIT = FALSE") %}
{% endmacro %}

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