Блог

У меня есть хранимая процедура в Snowflake, которая вызывает две другие хранимые процедуры. Это выполняется в Snowflake и успешно работает. Я хочу назвать это с помощью ADF. Я уже пробовал вызывать другие хранимые процедуры в конвейере ADF, и они работают с помощью действия поиска. Однако он не работает для этой конкретной основной процедуры. Я думаю, что ADF не может перейти к детским процедурам.

Образец запроса на снежинку:

 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; $ ;  

Конструкция АПД:

Поисковый запрос:

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

Передача имени базы данных в качестве параметра