在表中输入数据时运行小脚本



我在雪花文档中找不到这些信息,所以我决定在这里询问。我的用例要求我在雪花表中有新数据条目时运行一个小脚本。我知道snowflake支持SQL任务,但我的要求有点数学化,我需要一个合适的脚本来解决它。我对脚本的语言很灵活,但我想知道这个工作流是否有持续的集成。

我知道运行某个云平台上托管的按需实例的替代解决方案,但我想知道在Snowflake托管的仓库中是否可以实现这样的解决方案。

如有任何回复,不胜感激。提前谢谢。

您可以使用Steams和Tasks:来实现您的目标

  1. 在您的表上创建一个流(APPEND_ONLY=TRUE可能,因为您只需要搜索新条目(
  2. 创建一个存储过程(从今天起,您需要用Javascript编写它(,它消耗Stream并执行您需要的计算
  3. 创建一个计划每1分钟运行一次的任务,并且仅当流不为空时(SYSTEM$stream_HAS_DATA('<stream_name>'((,该任务将在(2(运行存储过程

最新更新