我在雪花文档中找不到这些信息,所以我决定在这里询问。我的用例要求我在雪花表中有新数据条目时运行一个小脚本。我知道snowflake支持SQL任务,但我的要求有点数学化,我需要一个合适的脚本来解决它。我对脚本的语言很灵活,但我想知道这个工作流是否有持续的集成。
我知道运行某个云平台上托管的按需实例的替代解决方案,但我想知道在Snowflake托管的仓库中是否可以实现这样的解决方案。
如有任何回复,不胜感激。提前谢谢。
您可以使用Steams和Tasks:来实现您的目标
- 在您的表上创建一个流(APPEND_ONLY=TRUE可能,因为您只需要搜索新条目(
- 创建一个存储过程(从今天起,您需要用Javascript编写它(,它消耗Stream并执行您需要的计算
- 创建一个计划每1分钟运行一次的任务,并且仅当流不为空时(SYSTEM$stream_HAS_DATA('<stream_name>'((,该任务将在(2(运行存储过程