我正在尝试使用合并查询在数据构建工具中实现 scd1。但我没有得到在增量模型中编写此查询的确切方法。
任何人都可以显示我们必须在哪里编写合并查询。
{{
config(
materialized='incremental'
)
}}
<MERGE QUERY HERE>
{% if is_incremental() %}
where last_modified_date > '2020-07-11'
{% endif %}
我正在尝试使用合并查询在数据构建工具中实现 scd1。但我没有得到在增量模型中编写此查询的确切方法。
任何人都可以显示我们必须在哪里编写合并查询。
{{
config(
materialized='incremental'
)
}}
<MERGE QUERY HERE>
{% if is_incremental() %}
where last_modified_date > '2020-07-11'
{% endif %}
您实际上不需要编写合并语句,dbt 会为您处理。您应该编写一个查询,该查询将返回您要更新插入的记录。然后,您可以检查 dbt 生成的合并查询的日志。
另请查看有关配置增量模型的 dbt 文档:https ://docs.getdbt.com/docs/building-a-dbt-project/building-models/configuring-incremental-models#what-is-an-incremental_strategy