使用 DBT 创建 Join 查询,但结果省略了一些列
Using DBT to create Join queries, but result omits some columns
我有以下代码使用右连接将我的数据从 Table 1 连接到 Table 2。DBT 成功编译了代码,没有错误,但我没有得到我的列需要...
{{
config(
materialized='incremental'
)
}}
with incremental_salesorder as (
select * from {{ source('db_warehouse', 'sale_order_line') }}
),
final as (
select
distinct incremental_salesorder.product_code_cust,
incremental_salesorder.order_id as id,
incremental_salesorder.create_date,
incremental_salesorder.name as product_name,
incremental_salesorder.product_name_cust,
sale_order.name as sale_order_ref
from incremental_salesorder
right join {{ source('db_warehouse', 'sale_order')}} using (id)
ORDER BY incremental_salesorder.create_date
)
{% if is_incremental() %}
where incremental_salesorder.create_date >= (select max(create_date) from {{ this }} )
{% endif %}
select * from final
incremental_salesorder.order_id
和incremental_salesorder.name
不在代码编译成功后的结果中
我在这里做错了什么...?
菜鸟错误:
确保定义的模型名称相同:
models:
dbt_test:
# Applies to all files under models/example/
example:
materialized: view
+schema: staging
+enabled: false
sales_order_unique_incremental: <- this line must match the folder name
materialized: table
+schema: datastudio
我完全错过了警告。一旦这个问题得到纠正,我就能够编译查询并获得我需要的结果。如果有人需要如何进行连接的示例,这是一种可行的方法:)
我有以下代码使用右连接将我的数据从 Table 1 连接到 Table 2。DBT 成功编译了代码,没有错误,但我没有得到我的列需要...
{{
config(
materialized='incremental'
)
}}
with incremental_salesorder as (
select * from {{ source('db_warehouse', 'sale_order_line') }}
),
final as (
select
distinct incremental_salesorder.product_code_cust,
incremental_salesorder.order_id as id,
incremental_salesorder.create_date,
incremental_salesorder.name as product_name,
incremental_salesorder.product_name_cust,
sale_order.name as sale_order_ref
from incremental_salesorder
right join {{ source('db_warehouse', 'sale_order')}} using (id)
ORDER BY incremental_salesorder.create_date
)
{% if is_incremental() %}
where incremental_salesorder.create_date >= (select max(create_date) from {{ this }} )
{% endif %}
select * from final
incremental_salesorder.order_id
和incremental_salesorder.name
不在代码编译成功后的结果中
我在这里做错了什么...?
菜鸟错误:
确保定义的模型名称相同:
models:
dbt_test:
# Applies to all files under models/example/
example:
materialized: view
+schema: staging
+enabled: false
sales_order_unique_incremental: <- this line must match the folder name
materialized: table
+schema: datastudio
我完全错过了警告。一旦这个问题得到纠正,我就能够编译查询并获得我需要的结果。如果有人需要如何进行连接的示例,这是一种可行的方法:)