无法通过ADF lookup活动调用Snowflake含子过程的主存储过程

在Snowflake中创建了包含子存储过程调用的主存储过程，Snowflake本地可正常执行，但通过ADF的Lookup活动调用时始终失败，推测是ADF无法识别存储过程的嵌套调用链路。

Snowflake示例代码 #

CREATE OR REPLACE PROCEDURE CHILD1(DBNAME VARCHAR)
RETURNS VARCHAR(16777216)
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS 
$$
var result="";
var sql_command = `Truncate table if exists ${DBNAME}.PUBLIC.EMPLOYEE`;
snowflake.execute ({sqlText: sql_command});
return result;
$$
;

CREATE OR REPLACE PROCEDURE MASTER(DBNAME VARCHAR)
RETURNS VARCHAR(16777216)
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS 
$$
var result="";
var sql_command = `CALL CHILD1(?)`;
snowflake.execute ({sqlText: sql_command, binds: [DBNAME]});
return result;
$$
;

原有ADF错误配置点 #

• Lookup查询语句写法：@concat('CALL PUBLIC.EMPLOYEE(',pipeline().parameters.DB_NAME,')')

首先明确：ADF本身不感知Snowflake存储过程的内部调用逻辑，调用失败和嵌套子过程没有直接关系，问题出在调用配置、权限或存储过程内部的上下文适配问题，按以下步骤排查修改即可：

1. 修正调用的存储过程名称 #

你在Lookup活动中写的调用语句指定的存储过程名为EMPLOYEE，但实际创建的主存储过程名称是MASTER，这是最直接的报错原因。

2. 修正参数传递格式 #

Snowflake中字符串类型的入参需要用单引号包裹，你当前的拼接逻辑没有加引号，会导致生成的SQL语法错误，修改后的表达式为：

@concat('CALL PUBLIC.MASTER(''', pipeline().parameters.DB_NAME, ''')')

更稳妥的方式是使用ADF的动态表达式参数绑定，既可以避免SQL注入风险，也不需要手动处理引号转义。

3. 补全存储过程内部的子过程定位逻辑 #

你在MASTER存储过程中调用CHILD1时没有指定所在的数据库和schema，当ADF连接的会话默认上下文和你本地测试的上下文不一致时，会找不到CHILD1存储过程，两种修改方式二选一：

• 方式1：调用子过程时写全限定名

var sql_command = `CALL ${DBNAME}.PUBLIC.CHILD1(?)`;

• 方式2：在MASTER存储过程开头先设置会话搜索路径

snowflake.execute({sqlText: `USE SCHEMA ${DBNAME}.PUBLIC`});

4. 验证ADF连接账号的权限 #

你的存储过程配置的是EXECUTE AS CALLER，即执行权限取调用者的权限，需要确认ADF连接Snowflake用的账号具备以下权限：

• 主存储过程MASTER的执行权限
• 子存储过程CHILD1的执行权限
• 目标表${DBNAME}.PUBLIC.EMPLOYEE的TRUNCATE权限

修改完成后先在Snowflake控制台用ADF的连接账号测试调用CALL PUBLIC.MASTER('测试库名')，确认执行成功后再到ADF中触发管道测试即可。

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