dbt - 如何在DBT中使用Update语句

Question

如何在DBT中使用Update语句？我们使用 DBT 在 Snowflake 中创建了表，但无法使用更新查询来更新同一个表。

是否有其他方法可以实现这一目标，例如其他 ELT/ETL 工具？

Answer 1

我也遇到了这个问题，根据这个 dic https://docs.getdbt.com/docs/building-a-dbt-project/building-models/configuring-incremental-models

{{ 
config(
    materialized='incremental',
    unique_key='payment_id',
    incremental_strategy='insert_overwrite'
)
}}

select
    ...
from orders o
    left join member m on o.member_id = m.member_id
    left join payment p on o.order_id = p.order_id
{% if is_incremental() %}
    where 1=1
        and p.gmt_updated >= (select max(payment_gmt_updated) from {{ this }})
{% endif %}

当源表付款更新时 ->“dbt run” -> 我的接收器表也得到更新(具有相同的 payment_id)