在DBT中合并建表与更新逻辑到单一模型的实现方案咨询

完全可以将两段逻辑合并到同一个T1.sql文件中，无需额外创建其他模型或表，具体实现方式如下：

核心思路 #

DBT表模型的底层逻辑是CREATE TABLE T1 AS (你的SELECT语句)，你原本的UPDATE操作完全可以通过CASE表达式转换为SELECT阶段的字段计算逻辑，不需要先建基础表再执行更新，直接一步查询得到最终结果即可。

具体代码实现 #

你可以直接把字段计算逻辑叠加在原始表查询上，T1.sql内容如下：

SELECT
  c1,
  c2,
  c3,
  CASE WHEN c1 = 'US' THEN 3.3 ELSE c4 END AS c4
  -- 其余需要保留的member表字段可在此处补充
FROM member

如果想要保留原来的分层逻辑便于后续维护，也可以用CTE封装两段逻辑，同样符合单SELECT的要求：

WITH base_t1 AS (
  SELECT * FROM member
)
SELECT
  c1,
  c2,
  c3,
  CASE WHEN c1 = 'US' THEN 3.3 ELSE c4 END AS c4
FROM base_t1

方案优势 #

• 符合DBT单模型仅允许一条SELECT语句的语法要求
• 全程使用幂等查询逻辑，重复运行模型也不会出现数据错误，符合DBT最佳实践
• 无需额外创建中间表或模型，最终生成的T1表和你原先进建表+UPDATE的效果完全一致

内容的提问来源于stack exchange，提问作者Gaganpreet Singh