Snowflake动态表配置咨询：仅三源表均加载前一日数据时刷新

关于DOWNSTREAM lag的适用性 #

DOWNSTREAM lag参数主要用于控制动态表相对于单个上游表的延迟容忍度，比如设定上游表数据滞后超过N小时就暂停刷新。但它没办法同时校验多个源表是否都存在指定日期（当前日期-1）的数据，所以无法直接满足你的需求。

可行的实现方案 #

方案1：CTE预校验共通日期+左连接 #

这是你提到的思路，完全可行。核心是先通过内连接筛选出三个表都存在的目标日期，再基于该日期范围执行左连接，确保只有当三个表都加载了前一天数据时，动态表才会生成对应日期的结果。

示例SQL：

CREATE OR REFRESH DYNAMIC TABLE dt_joined
TBLPROPERTIES ("delta.enableChangeDataFeed" = "true")
AS
WITH valid_process_dates AS (
    -- 筛选三个表共有的前一天数据日期
    SELECT DISTINCT process_date
    FROM tab1
    INNER JOIN tab2 USING(process_date)
    INNER JOIN tab3 USING(process_date)
    WHERE process_date = CURRENT_DATE() - INTERVAL 1 DAY
)
-- 基于有效日期执行左连接
SELECT 
    t1.*,
    t2.col1, t2.col2, -- 按需选取tab2字段，避免重复列
    t3.col_a, t3.col_b -- 按需选取tab3字段
FROM tab1 t1
LEFT JOIN tab2 t2 ON t1.process_date = t2.process_date AND t1.id = t2.id
LEFT JOIN tab3 t3 ON t1.process_date = t3.process_date AND t1.id = t3.id
INNER JOIN valid_process_dates vpd ON t1.process_date = vpd.process_date;

如果三个表中有一个未加载前一天的数据，valid_process_dates会返回空集，最终查询结果也为空，动态表不会产生新的版本，相当于不触发无效刷新。

方案2：EXISTS断言直接校验源表数据存在性 #

这种方式更直接，在查询的WHERE子句中加入对另外两个表的存在性校验，只有当三个表都有前一天的数据时，才会返回结果：

示例SQL：

CREATE OR REFRESH DYNAMIC TABLE dt_joined
TBLPROPERTIES (
    "delta.enableChangeDataFeed" = "true",
    "refresh.trigger.interval" = "1 hour" -- 按需设置刷新间隔
)
AS
SELECT 
    t1.*,
    t2.*,
    t3.*
FROM tab1 t1
LEFT JOIN tab2 t2 ON t1.process_date = t2.process_date AND t1.id = t2.id
LEFT JOIN tab3 t3 ON t1.process_date = t3.process_date AND t1.id = t3.id
WHERE 
    t1.process_date = CURRENT_DATE() - INTERVAL 1 DAY
    AND EXISTS (SELECT 1 FROM tab2 WHERE process_date = CURRENT_DATE() - INTERVAL 1 DAY)
    AND EXISTS (SELECT 1 FROM tab3 WHERE process_date = CURRENT_DATE() - INTERVAL 1 DAY);

当任意一个源表缺少前一天数据时，WHERE条件不满足，查询结果为空，动态表不会更新，直到三个表都满足条件为止。

补充说明 #

动态表的刷新逻辑是基于上游表的变更和最终查询结果的变化——如果查询结果没有新增数据（比如上述场景中结果为空），动态表不会生成新的版本，也就不会触发无效的刷新操作，完全符合你等待所有源表就绪再刷新的需求。

内容的提问来源于stack exchange，提问作者Robertino Bonora