From 4e227b02aa7dba87ce710c5aff94544551e5a779 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Sun, 6 Aug 2023 07:17:28 +0000 Subject: [PATCH] base model --- .../base_exchange__voucher_redemptions.sql | 50 +++++++++++++++++++ 1 file changed, 50 insertions(+) create mode 100644 models/staging/exchange/base/base_exchange__voucher_redemptions.sql diff --git a/models/staging/exchange/base/base_exchange__voucher_redemptions.sql b/models/staging/exchange/base/base_exchange__voucher_redemptions.sql new file mode 100644 index 0000000..3f62da6 --- /dev/null +++ b/models/staging/exchange/base/base_exchange__voucher_redemptions.sql @@ -0,0 +1,50 @@ +-- IMPORTS +WITH source AS ( + SELECT * FROM {{ source('src_exchange_mysql', 'voucher_redemptions') }} + +), + +-- LOGIC +voucher_redemptions_rename AS ( + + SELECT + id AS voucher_redemption_id, + voucher_id, + transaction_id, + redemption_id, + value AS voucher_credit, + 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__voucher_redemptions AS ( + + SELECT + -- ids + voucher_redemption_id, + voucher_id, + transaction_id, + redemption_id, + + -- dimensions + voucher_credit, + + -- measures + + -- date/times + created_datetime, + updated_datetime, + + -- metadata + _dbt_ran_datetime + + FROM voucher_redemptions_rename + +) + +SELECT * FROM final__base_exchange__voucher_redemptions