diff --git a/models/staging/exchange/base/base_exchange__wallet_logs.sql b/models/staging/exchange/base/base_exchange__wallet_logs.sql new file mode 100644 index 0000000..c5b13d5 --- /dev/null +++ b/models/staging/exchange/base/base_exchange__wallet_logs.sql @@ -0,0 +1,58 @@ +-- IMPORT +WITH source AS ( + SELECT * FROM {{ source('src_exchange_mysql', 'wallet_logs') }} +), + + +-- LOGIC +renamed AS ( + + SELECT + id AS wallet_log_id, + wallet_id, + owner_type, + owner_id, + code, + currency_id, + amount, + deleted_at AS deleted_datetime, + created_at AS created_datetime, + updated_at AS updated_datetime, + + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime + + FROM source + +), + + +-- FINAL +final__base_exchange__wallet_logs AS ( + + SELECT + -- ids + wallet_log_id, + wallet_id, + owner_id, + currency_id, + + -- dimensions + owner_type, + code, + + -- measures + amount, + + -- date/time + created_datetime, + updated_datetime, + deleted_datetime, + + -- metadata + _dbt_ran_datetime + + FROM renamed + +) + +SELECT * FROM final__base_exchange__wallet_logs \ No newline at end of file diff --git a/models/staging/exchange/base/base_exchange__wallets.sql b/models/staging/exchange/base/base_exchange__wallets.sql new file mode 100644 index 0000000..ead58e7 --- /dev/null +++ b/models/staging/exchange/base/base_exchange__wallets.sql @@ -0,0 +1,56 @@ +-- IMPORT +WITH source AS ( + SELECT * FROM {{ source('src_exchange_mysql', 'wallets') }} +), + + +-- LOGIC +renamed AS ( + + SELECT + id AS wallet_id, + owner_type, + owner_id, + code, + currency_id, + amount, + deleted_at AS deleted_datetime, + created_at AS created_datetime, + updated_at AS updated_datetime, + + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime + + FROM source + +), + + +-- FINAL +final__base_exchange__wallets AS ( + + SELECT + -- ids + wallet_id, + owner_id, + currency_id, + + -- dimensions + owner_type, + code, + + -- measures + amount, + + -- date/time + created_datetime, + updated_datetime, + deleted_datetime, + + -- metadata + _dbt_ran_datetime + + FROM renamed + +) + +SELECT * FROM final__base_exchange__wallets \ No newline at end of file