【发布时间】:2021-12-23 12:41:38
【问题描述】:
我想在雪花中创建任务时使用变量。例如下面:
- 改为:
创建或替换任务 BEAST_DSC_SBX.DSC_STG.DTCI_DSC_R2O_AVAIL_INCREMENTAL_TRUNCATE WAREHOUSE = 'BEAST_DSC_ADHOC_WH_SBX' SCHEDULE = '10 MINUTE' 当 SYSTEM$STREAM_HAS_DATA('BEAST_DSC_SBX.KAFKA.DTCI_DSC_R2O_AVAIL_CHANGES') = True 作为 TRUNCATE TABLE BEAST_DSC_SBX.DSC_STG.DTCI_DSC_R2O_AVAIL_INCREMENTAL;
- 我想用这个:
SET STG_SCHEMA_NAME = 'BEAST_DSC_SBX.DSC_STG'; SET KAFKA_SCHEMA_NAME = 'BEAST_DSC_SBX.KAFKA';
创建或替换任务 $STG_SCHEMA_NAME.DTCI_DSC_R2O_AVAIL_INCREMENTAL_TRUNCATE WAREHOUSE = $WAREHOUSE SCHEDULE = '10 MINUTE' 当 SYSTEM$STREAM_HAS_DATA($KAFKA_SCHEMA_NAME'.DTCI_DSC_R2O_AVAIL_CHANGES') = True 作为 截断表 $STG_SCHEMA_NAME.DTCI_DSC_R2O_AVAIL_INCREMENTAL;
执行上述操作时出现错误。甚至可以改变雪花任务吗?如果是,怎么做?
【问题讨论】:
-
您可以尝试使用
INDENTIFIER($MY_VARIABLE)将变量包装在create 语句中。如果这不起作用,您可以使用存储过程使用动态名称创建它们。
标签: snowflake-cloud-data-platform snowflake-schema