Deduplicated records
This commit is contained in:
parent
2e19678182
commit
62c2e44b86
1 changed files with 6 additions and 2 deletions
|
|
@ -1,4 +1,8 @@
|
||||||
with raw_incident as (select * from {{ source("resolutions", "incident") }})
|
with
|
||||||
|
raw_incident as (select * from {{ source("resolutions", "incident") }}),
|
||||||
|
deduped_verifications as (
|
||||||
|
{{ cosmos_db_record_deduplication("raw_incident", "id") }}
|
||||||
|
)
|
||||||
select
|
select
|
||||||
-- Basic Incident Details
|
-- Basic Incident Details
|
||||||
{{ adapter.quote("documents") }} ->> 'id' as id_incident,
|
{{ adapter.quote("documents") }} ->> 'id' as id_incident,
|
||||||
|
|
@ -278,4 +282,4 @@ select
|
||||||
(({{ adapter.quote("documents") }} ->> '_ts'))::integer
|
(({{ adapter.quote("documents") }} ->> '_ts'))::integer
|
||||||
) as cosmos_db_timestamp_utc
|
) as cosmos_db_timestamp_utc
|
||||||
|
|
||||||
from raw_incident
|
from deduped_verifications
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue