progress in staging, ordered fields
This commit is contained in:
parent
2331db2803
commit
64e5d78578
1 changed files with 57 additions and 0 deletions
57
models/staging/edeposit/stg_edeposit__verifications.sql
Normal file
57
models/staging/edeposit/stg_edeposit__verifications.sql
Normal file
|
|
@ -0,0 +1,57 @@
|
|||
with
|
||||
raw_verifications as (select * from {{ source("edeposit", "verifications") }}),
|
||||
stg_edeposit__verifications as (
|
||||
select
|
||||
{{ adapter.quote("documents") }} ->> 'id' as id,
|
||||
{{ 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") }} ->> '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") }} ->> 'GuestEmail' as guest_email,
|
||||
{{ adapter.quote("documents") }} ->> 'UserEmail' as user_email,
|
||||
{{ adapter.quote("documents") }} ->> 'GuestLastName' as guest_last_name,
|
||||
{{ adapter.quote("documents") }} ->> 'GuestFirstName' as guest_first_name,
|
||||
{{ adapter.quote("documents") }} ->> 'GuestTelephone' as guest_telephone,
|
||||
|
||||
{{ adapter.quote("documents") }}
|
||||
->> 'PropertyManagerName' as property_manager_name,
|
||||
{{ adapter.quote("documents") }}
|
||||
->> 'PropertyManagerEmail' as property_manager_email,
|
||||
{{ adapter.quote("documents") }} ->> 'ListingName' as listing_name,
|
||||
{{ adapter.quote("documents") }} ->> 'ListingTown' as listing_town,
|
||||
|
||||
{{ 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") }}
|
||||
->> 'LevelOfProtectionAmount' as level_of_protection_amount,
|
||||
{{ adapter.quote("documents") }}
|
||||
->> 'LevelOfProtectionCurrency' 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
|
||||
from raw_verifications
|
||||
)
|
||||
select *
|
||||
from stg_edeposit__verifications
|
||||
Loading…
Add table
Add a link
Reference in a new issue