有没有人创建了一个程序来手动清除雪花中的流?

Mat*_*ian 6 stream cdc type-2-dimension snowflake-cloud-data-platform

我正在寻找一段代码,它将导致流清空,本质上是重置它。这是用例。我们使用流来跟踪数据集市中类型 2 维度表的更改。有时需要我们截断并重新加载维度表以修复缺陷或其他数据问题。发生这种情况时,流需要重置以仅在重新加载发生后开始捕获更改。Snowflake没有像ALTER STREAM PURGE这样的功能来为我们管理这个,所以我们需要自己做。我不想每次需要执行此操作时都发出 CREATE OR REPLACE STREAM 语句。

Mik*_*ton 9

与 Greg 类似,如果插入现有表让您感到紧张,您可以运行类似的操作。

CREATE OR REPLACE TEMP TABLE RESET_TBL AS
SELECT * FROM THE_STREAM;
Run Code Online (Sandbox Code Playgroud)