Mat*_*ian 6 stream cdc type-2-dimension snowflake-cloud-data-platform
我正在寻找一段代码,它将导致流清空,本质上是重置它。这是用例。我们使用流来跟踪数据集市中类型 2 维度表的更改。有时需要我们截断并重新加载维度表以修复缺陷或其他数据问题。发生这种情况时,流需要重置以仅在重新加载发生后开始捕获更改。Snowflake没有像ALTER STREAM PURGE这样的功能来为我们管理这个,所以我们需要自己做。我不想每次需要执行此操作时都发出 CREATE OR REPLACE STREAM 语句。
与 Greg 类似,如果插入现有表让您感到紧张,您可以运行类似的操作。
CREATE OR REPLACE TEMP TABLE RESET_TBL AS
SELECT * FROM THE_STREAM;
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
5049 次 |
| 最近记录: |