build base wallets

2026-08-19 04:14:00 +00:00 · 2024-03-06 03:42:37 +00:00
parent 85b6720569
commit dd42248cdd
2 changed files with 114 additions and 0 deletions
@@ -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
@@ -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