存储过程中的 Snowflake 'get' 语句不起作用
Snowflake 'get' statement within stored procedure not working
问题陈述:snowflake 'get' 语句在 snowflake 存储过程中不起作用。
CREATE OR REPLACE PROCEDURE SP_UNLOAD_DYNAMIC("prefix" varchar)
RETURNS varchar(1000)
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS
$$
var result = "";
try {
var sql00 = "select concat('" + prefix + "', to_char(ts,'yyyymmddhh24miss'),'.txt') from ts";
var stmt00 = snowflake.execute({ sqlText:sql00 });
stmt00.next();
var rs = stmt00.getColumnValue(1);
var sql01 = "copy into @my_unload_stage/unload/" + rs + " from tmp_dedupe header=false single=true max_file_size=4900000000 overwrite=true;"
var stmt01 = snowflake.execute({ sqlText:sql01 });
stmt01.next();
var sql02 = 'get @my_unload_stage file://D:\project_x\OutputFiles_STG\';
var stmt02 = snowflake.execute({ sqlText:sql02 });
stmt02.next();
result = rs;
}
catch (err) {
result = "Failed: Code: " + err.code + "\n State: " + err.state;
result += "\n Message: " + err.message;
result += "\nStack Trace:\n" + err.stackTraceTxt;
}
return result;
$$;
在 stmt02 之前似乎一切正常。 get语句在snowsql中有效,在存储过程中无效
想法,并提前谢谢你。
-伊比
我认为您不能从存储过程中执行 GET
语句。您会要求 Snowflake 联系客户并将文件移动到该客户。 Snowflake VWH 如何知道客户在哪里做那件事?
为了完成您正在做的事情,我相信您需要创建一个利用 Snowflake 连接器之一的外部应用程序,例如 Python、JDBC、ODBC 等. 支持 GET
然后可能在 Lambda 或 Azure 函数中公开它。然后,您可以从 Snowflake 存储过程中通过 Snowflake 外部函数调用 API。
https://docs.snowflake.com/en/sql-reference/external-functions.html
问题陈述:snowflake 'get' 语句在 snowflake 存储过程中不起作用。
CREATE OR REPLACE PROCEDURE SP_UNLOAD_DYNAMIC("prefix" varchar)
RETURNS varchar(1000)
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS
$$
var result = "";
try {
var sql00 = "select concat('" + prefix + "', to_char(ts,'yyyymmddhh24miss'),'.txt') from ts";
var stmt00 = snowflake.execute({ sqlText:sql00 });
stmt00.next();
var rs = stmt00.getColumnValue(1);
var sql01 = "copy into @my_unload_stage/unload/" + rs + " from tmp_dedupe header=false single=true max_file_size=4900000000 overwrite=true;"
var stmt01 = snowflake.execute({ sqlText:sql01 });
stmt01.next();
var sql02 = 'get @my_unload_stage file://D:\project_x\OutputFiles_STG\';
var stmt02 = snowflake.execute({ sqlText:sql02 });
stmt02.next();
result = rs;
}
catch (err) {
result = "Failed: Code: " + err.code + "\n State: " + err.state;
result += "\n Message: " + err.message;
result += "\nStack Trace:\n" + err.stackTraceTxt;
}
return result;
$$;
在 stmt02 之前似乎一切正常。 get语句在snowsql中有效,在存储过程中无效
想法,并提前谢谢你。
-伊比
我认为您不能从存储过程中执行 GET
语句。您会要求 Snowflake 联系客户并将文件移动到该客户。 Snowflake VWH 如何知道客户在哪里做那件事?
为了完成您正在做的事情,我相信您需要创建一个利用 Snowflake 连接器之一的外部应用程序,例如 Python、JDBC、ODBC 等. 支持 GET
然后可能在 Lambda 或 Azure 函数中公开它。然后,您可以从 Snowflake 存储过程中通过 Snowflake 外部函数调用 API。
https://docs.snowflake.com/en/sql-reference/external-functions.html