snowflake-task - 基于雪花事件的任务调度而不是基于时间的任务调度

Question

我需要基于雪花事件的任务调度而不是基于时间的任务调度的示例。我在雪花文档中找不到这些示例。

提前致谢

Answer 1

唯一可以触发任务的事件源是任务树中先前任务的完成，请参阅使用“AFTER”参数。

CREATE TASK mytask2
  WAREHOUSE = mywh
  AFTER mytask1
AS
INSERT INTO mytable2(id,name) SELECT id, name FROM mytable1;

此外，如果事件是对表中记录的插入或更改，您可以在表上创建一个流并使用 WHEN 子句来阻止计划任务运行，直到流有数据。

create stream mystream on table mytable
APPEND_ONLY = TRUE; // Set to true to only capture inserts

CREATE TASK mytask1
  WAREHOUSE = mywh
  SCHEDULE = '5 minute'
WHEN
  SYSTEM$STREAM_HAS_DATA('MYSTREAM')
AS
  INSERT INTO mytable1(id,name) SELECT id, name FROM mystream WHERE METADATA$ACTION = 'INSERT';

https://docs.snowflake.com/en/sql-reference/sql/create-task.html

https://docs.snowflake.com/en/sql-reference/sql/create-stream.html

Answer 2

没有可以触发任务的事件源；相反，任务按计划运行。

https://docs.snowflake.com/en/user-guide/tasks-intro.html#task-scheduling

因此，目前无法创建基于事件的任务调度。