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

some casts

Browse source
This commit is contained in:
Pablo Martin 2024-08-21 15:12:05 +02:00
parent 64e5d78578
commit 34a2279387
1 changed files with 27 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

45
models/staging/edeposit/stg_edeposit__verifications.sql
View file

@ -6,19 +6,22 @@ with
{{ adapter.quote("documents") }} ->> 'BookingId' as id_booking,
{{ adapter.quote("documents") }} ->> 'userId' as id_user,
{{ adapter.quote("documents") }} ->> 'Status' as status,
{{ adapter.quote("documents") }} ->> 'StatusReason' as status_reason,
{{ adapter.quote("documents") }} ->> 'Status' as verification_status,
{{ adapter.quote("documents") }}
->> 'StatusReason' as verification_status_reason,
{{ adapter.quote("documents") }} ->> 'EmailFlag' as email_flag,
{{ adapter.quote("documents") }} ->> 'PhoneFlag' as phone_flag,
{{ adapter.quote("documents") }} ->> 'WatchList' as watch_list,
{{ adapter.quote("documents") }} ->> 'Channel' as channel,
{{ adapter.quote("documents") }} ->> 'CheckIn' as checkin,
{{ adapter.quote("documents") }} ->> 'CheckOut' as checkout,
{{ adapter.quote("documents") }} ->> 'Cancelled' as cancelled,
{{ adapter.quote("documents") }}
->> 'CancellationDate' as cancellation_date,
({{ adapter.quote("documents") }} ->> 'CheckIn')::timestamp
as checkin_at_utc,
({{ adapter.quote("documents") }} ->> 'CheckOut')::timestamp
as checkout_at_utc,
({{ adapter.quote("documents") }} ->> 'Cancelled')::boolean as is_cancelled,
({{ adapter.quote("documents") }} ->> 'CancellationDate')::timestamp
as cancelled_at_utc,
{{ adapter.quote("documents") }} ->> 'GuestEmail' as guest_email,
{{ adapter.quote("documents") }} ->> 'UserEmail' as user_email,
@ -36,21 +39,27 @@ with
{{ adapter.quote("documents") }} ->> 'ListingAddress' as listing_address,
{{ adapter.quote("documents") }} ->> 'ListingCountry' as listing_country,
{{ adapter.quote("documents") }} ->> 'ListingPostcode' as listing_postcode,
{{ adapter.quote("documents") }} ->> 'PetsAllowed' as pets_allowed,
({{ adapter.quote("documents") }} ->> 'PetsAllowed')::boolean
as pets_allowed,
{{ adapter.quote("documents") }}
->> 'LevelOfProtectionAmount' as level_of_protection_amount,
{{ adapter.quote("documents") }}
->> 'LevelOfProtectionCurrency' as level_of_protection_currency,
({{ adapter.quote("documents") }} ->> 'LevelOfProtectionAmount')::float
::integer as level_of_protection_amount,
({{ adapter.quote("documents") }} ->> 'LevelOfProtectionCurrency')::integer
as level_of_protection_currency,
{{ adapter.quote("documents") }} ->> '_attachments' as attachments,
{{ adapter.quote("documents") }}
->> 'StatusUpdatedDate' as status_updated_date,
{{ adapter.quote("documents") }} ->> 'UpdatedDate' as updated_date,
{{ adapter.quote("documents") }} ->> 'CreationDate' as creation_date,
{{ adapter.quote("documents") }} ->> 'CreatedDate' as created_date,
{{ adapter.quote("documents") }} ->> '_ts' as cosmos_db_timestamp_utc
({{ adapter.quote("documents") }} ->> 'StatusUpdatedDate')::timestamp
as status_updated_at_utc,
({{ adapter.quote("documents") }} ->> 'UpdatedDate')::timestamp
as updated_at_utc,
({{ adapter.quote("documents") }} ->> 'CreationDate')::timestamp
as creation_at_utc,
({{ adapter.quote("documents") }} ->> 'CreatedDate')::timestamp
as created_at_utc,
to_timestamp(
(({{ adapter.quote("documents") }} ->> '_ts'))::integer
) as cosmos_db_timestamp_utc
from raw_verifications
)
select *