如何在ADF中通过新Snowflake连接器调用带参数的存储过程

1. 先在Snowflake中创建接收参数的存储过程 #

先编写一个存储过程，用于接收员工姓名参数，动态生成并创建对应名称的表（注意用标识符包裹表名，避免特殊字符导致的语法问题）：

CREATE OR REPLACE PROCEDURE CREATE_EMPLOYEE_TABLE(EMPNAME VARCHAR)
RETURNS VARCHAR
LANGUAGE SQL
AS
$$
BEGIN
  EXECUTE IMMEDIATE 'CREATE TABLE IF NOT EXISTS "' || EMPNAME || '" (
    EMP_ID INT,
    DEPT VARCHAR(50),
    JOIN_DATE DATE
  )';
  RETURN 'Table ' || EMPNAME || ' created successfully';
END;
$$;

2. ADF Foreach Activity 内部配置Snowflake Script Activity #

你已经通过Lookup Activity拿到了EMP_NAME表的EMPNAME数据，接下来按以下步骤配置Foreach内部的Script Activity：

2.1 绑定Foreach循环数据源 #

将Foreach的Items属性设置为Lookup Activity的输出结果：
@activity('Lookup EMP Names').output.value

2.2 配置Snowflake Script Activity #

• 选择已配置好的Snowflake链接服务，确保该服务对应的Snowflake角色拥有创建表的权限。
• 在Script输入框中，使用ADF动态内容传入当前循环的员工姓名，调用存储过程：

  CALL CREATE_EMPLOYEE_TABLE('@{item().EMPNAME}');
  

  其中@{item().EMPNAME}会自动替换为当前循环迭代的员工姓名值。

2.3 特殊字符处理（可选） #

如果EMPNAME包含单引号等特殊字符，需要先转义避免SQL语法错误，修改脚本为：

CALL CREATE_EMPLOYEE_TABLE('@{replace(item().EMPNAME, ''', '''''')}');

2.4 调试辅助 #

可以在Script Activity的Settings面板中开启执行日志，方便排查循环过程中的执行错误。

3. 验证执行结果 #

运行流水线后，在Snowflake对应数据库的schema下，检查是否生成了所有以员工姓名命名的表。

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