counterweight/data-dwh-dbt-project
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

improve stg_stripe__balance_transactions

Browse source
This commit is contained in:
Pablo Martin 2024-02-23 16:17:26 +01:00
parent d262aff8c2
commit 9c423e3f3c
1 changed files with 19 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

25
models/staging/stripe/stg_stripe__balance_transactions.sql
View file

@ -2,27 +2,40 @@ with
raw_balance_transactions as ( raw_balance_transactions as (
select * from {{ source("stripe_uk", "balance_transactions") }} select * from {{ source("stripe_uk", "balance_transactions") }}
), ),
stg_seed__currencies as (select * from {{ ref("stg_seed__currencies") }}),
stg_stripe__balance_transactions as ( stg_stripe__balance_transactions as (
select select
{{ adapter.quote("id") }}, {{ adapter.quote("id") }},
{{ adapter.quote("fee") }}, {{ adapter.quote("fee") }} / (10 ^ cur.decimal_positions) as fee,
{{ adapter.quote("net") }}, {{ adapter.quote("net") }} / (10 ^ cur.decimal_positions) as net,
{{ adapter.quote("type") }}, {{ adapter.quote("type") }},
{{ adapter.quote("amount") }}, {{ adapter.quote("amount") }} / (10 ^ cur.decimal_positions) as amount,
{{ adapter.quote("object") }}, {{ adapter.quote("object") }},
{{ adapter.quote("source") }}, {{ adapter.quote("source") }},
{{ adapter.quote("status") }}, {{ adapter.quote("status") }},
to_timestamp({{ adapter.quote("created") }}) as created_at_utc, to_timestamp({{ adapter.quote("created") }}) as created_at_utc,
{{ adapter.quote("currency") }}, cast(
to_timestamp({{ adapter.quote("created") }}) as date
) as created_date_utc,
upper({{ adapter.quote("currency") }}) as currency,
{{ adapter.quote("description") }}, {{ adapter.quote("description") }},
{{ adapter.quote("fee_details") }}, {{ adapter.quote("fee_details") }},
to_timestamp({{ adapter.quote("available_on") }}) as available_at_utc, to_timestamp({{ adapter.quote("available_on") }}) as available_at_utc,
cast(
to_timestamp({{ adapter.quote("available_on") }}) as date
) as available_date_utc,
{{ adapter.quote("exchange_rate") }}, {{ adapter.quote("exchange_rate") }},
{{ adapter.quote("sourced_transfers") }}, {{ adapter.quote("sourced_transfers") }},
{{ adapter.quote("reporting_category") }}, {{ adapter.quote("reporting_category") }},
{{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_date {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_utc,
cast(
{{ adapter.quote("_airbyte_extracted_at") }} as date
) as dwh_extracted_date_utc
from raw_balance_transactions from raw_balance_transactions bt
left join
stg_seed__currencies cur
on upper(bt.{{ adapter.quote("currency") }}) = cur.iso_4217_code
) )
select * select *
from stg_stripe__balance_transactions from stg_stripe__balance_transactions