如何在Power BI数据模型刷新时调用Snowflake存储过程？

一、确认Snowflake存储过程就绪 #

假设你的存储过程负责将源表数据插入目标表，先确保存储过程已创建并测试通过，示例代码如下：

CREATE OR REPLACE PROCEDURE COPY_DATA_TO_TARGET()
RETURNS VARCHAR
LANGUAGE SQL
AS
$$
BEGIN
  INSERT INTO TARGET_DB.SCHEMA.TARGET_TABLE
  SELECT * FROM SOURCE_DB.SCHEMA.SOURCE_TABLE
  -- 可按需添加过滤或去重逻辑，比如基于主键避免重复插入
  WHERE NOT EXISTS (
    SELECT 1 FROM TARGET_DB.SCHEMA.TARGET_TABLE t
    WHERE t.ID = SOURCE_DB.SCHEMA.SOURCE_TABLE.ID
  );
  RETURN '数据插入完成，共插入 ' || SQLROWCOUNT || ' 条记录';
END;
$$;

执行CALL COPY_DATA_TO_TARGET();测试，确认数据正常插入目标表。

二、Power BI中配置调用逻辑 #

方法1：Power Query前置执行（推荐） #

1. 打开Power BI Desktop，进入数据加载编辑器
2. 点击新建源 → 选择Snowflake，完成实例连接
3. 在导航器的高级选项里选择SQL语句，输入调用语句：

   CALL COPY_DATA_TO_TARGET();
   

4. 加载该查询并命名为CallSnowflakeSP，设置其加载属性为仅创建连接（无需将返回结果导入模型）
5. 进入模型选项卡，点击刷新顺序，将CallSnowflakeSP设为所有业务表的前置刷新项，保证存储过程先执行再刷新数据。

方法2：云端数据流触发（适合定时刷新） #

如果使用Power BI服务的定时刷新，可通过数据流实现：

1. 在Power BI服务中创建数据流，连接目标Snowflake实例
2. 添加自定义查询，输入CALL COPY_DATA_TO_TARGET();
3. 将数据流与数据集关联，设置数据集刷新时先触发数据流执行，再刷新数据集内容。

三、权限配置要点 #

确保Power BI连接Snowflake的账号拥有：

• 存储过程执行权限：GRANT EXECUTE ON PROCEDURE COPY_DATA_TO_TARGET() TO ROLE YOUR_ROLE;
• 源表的SELECT权限和目标表的INSERT权限

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