Snowflake多语句任务执行报错:会话变量$DATE_PATTERN不存在
问题原因与解决方案
问题根源
你在任务中用$DATE_PATTERN引用会话变量是错误的——Snowflake里$前缀是用来引用外部阶段的文件列(比如$1代表文件第一列),而会话变量的正确引用方式是用:变量名。
修复方案1:修正变量引用方式
修改任务中的COPY语句,把pattern=$DATE_PATTERN改为pattern=>:DATE_PATTERN,完整代码如下:
CREATE OR REPLACE TASK sv_copy_command_test_task WAREHOUSE = compute_wh SCHEDULE = '1 MINUTE' AS BEGIN SET DATE_PATTERN = CONCAT('CALLS/', TO_CHAR(CURRENT_DATE(), 'YYYY/MM/DD'), '/', '.*[.]parquet'); copy into expose_sf_data_trial.decoded.CALLS_COPY_COMMAND from (select $1:LOAD_ID::varchar::TIMESTAMP_LTZ, 'mainnet' as CHAIN_ID from @expose_sf_data_trial.decoded.trial_calls_copy_command) pattern=>:DATE_PATTERN; END; / !set sql_delimiter=";"
修复方案2:直接内联表达式(更简洁)
你也可以跳过SET变量的步骤,直接把日期模式的计算逻辑写到COPY的pattern参数里,避免变量引用的问题:
CREATE OR REPLACE TASK sv_copy_command_test_task WAREHOUSE = compute_wh SCHEDULE = '1 MINUTE' AS copy into expose_sf_data_trial.decoded.CALLS_COPY_COMMAND from (select $1:LOAD_ID::varchar::TIMESTAMP_LTZ, 'mainnet' as CHAIN_ID from @expose_sf_data_trial.decoded.trial_calls_copy_command) pattern=>CONCAT('CALLS/', TO_CHAR(CURRENT_DATE(), 'YYYY/MM/DD'), '/', '.*[.]parquet'); / !set sql_delimiter=";"
补充说明
任务执行时确实是在独立会话中运行,但你定义的会话变量在BEGIN...END块内是有效的,问题核心是变量引用的语法错误,而非会话隔离导致的变量丢失。
内容的提问来源于stack exchange,提问作者svalls
相关产品推荐
相关产品推荐

