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

Removed agg model

Browse source
This commit is contained in:
Joaquin Ossa 2024-11-26 09:33:31 +01:00
parent b355d8cbc7
commit 2404905da1
1 changed files with 0 additions and 144 deletions
Download patch file Download diff file Expand all files Collapse all files

144
models/intermediate/kpis/int_kpis__product_guest_agg_metrics.sql
View file

@ -1,144 +0,0 @@
{% set yesterday = "(current_date - interval '1 day')" %}
{% set metric_names = (
"created_guest_journeys_not_cancelled",
"started_guest_journeys_not_cancelled",
"completed_guest_journeys_not_cancelled",
"created_guest_journeys",
"started_guest_journeys",
"completed_guest_journeys",
"total_csat_score_count",
"average_csat_score",
"deposit_fees_in_gbp",
"waiver_payments_in_gbp",
"checkin_cover_fees_in_gbp",
"total_guest_payments_in_gbp",
) %}
with
int_kpis__product_guest_daily_metrics as (
select
date_day,
has_payment,
has_id_check,
main_billing_country_iso_3_per_deal,
{% for metric in metric_names %}
{{ metric }}{% if not loop.last %},{% endif %}
{% endfor %}
from {{ ref("int_kpis__product_guest_daily_metrics") }}
),
date_ranges as (
select
{{ yesterday }} as current_date,
date_trunc('month', {{ yesterday }}) as current_month_start,
date_trunc('week', {{ yesterday }}) as current_week_start, -- Start of the current week
date_trunc('week', {{ yesterday }} - interval '1 year') as py_week_start, -- Start of the same week last year
date_trunc('week', {{ yesterday }} - interval '1 year')
+ interval '1 day'
* extract(
dow from {{ yesterday }} - interval '1 day'
) as py_week_current_date,
date_trunc('week', {{ yesterday }} - interval '1 week') as pp_week_start, -- Start of the same week in the previous period
date_trunc('month', {{ yesterday }} - interval '1 year') as py_month_start,
date_trunc('year', {{ yesterday }}) as current_year_start,
date_trunc('year', {{ yesterday }} - interval '1 year') as py_year_start,
date_trunc('month', {{ yesterday }} - interval '1 month') as pp_month_start,
{{ yesterday }} - interval '1 year' as py_current_date,
{{ yesterday }} - interval '1 month' as pm_current_date,
{{ yesterday }} - interval '1 week' as pw_current_date,
extract(day from {{ yesterday }}) as current_day_of_month
),
aggregated_metrics as (
{% for metric in metric_names %}
select
'{{ metric }}' as metric,
has_payment,
has_id_check,
main_billing_country_iso_3_per_deal,
'YTD' as timeframe,
sum(
case
when date_day between dr.current_year_start and {{ yesterday }}
then dm.{{ metric }}
end
) as current_value,
sum(
case
when date_day between dr.py_year_start and dr.py_current_date
then dm.{{ metric }}
end
) as py_value,
sum(
case
when date_day between dr.py_year_start and dr.py_current_date
then dm.{{ metric }}
end
) as pp_value
from int_kpis__product_guest_daily_metrics dm, date_ranges dr
where extract(day from date_day) <= dr.current_day_of_month
group by
metric, has_payment, has_id_check, main_billing_country_iso_3_per_deal
union all
select
'{{ metric }}' as metric,
has_payment,
has_id_check,
main_billing_country_iso_3_per_deal,
'MTD' as timeframe,
sum(
case
when date_day between dr.current_month_start and {{ yesterday }}
then dm.{{ metric }}
end
) as current_value,
sum(
case
when date_day between dr.py_month_start and dr.py_current_date
then dm.{{ metric }}
end
) as py_value,
sum(
case
when date_day between dr.pp_month_start and dr.pm_current_date
then dm.{{ metric }}
end
) as pp_value
from int_kpis__product_guest_daily_metrics dm, date_ranges dr
where extract(day from date_day) <= dr.current_day_of_month
group by
metric, has_payment, has_id_check, main_billing_country_iso_3_per_deal
union all
select
'{{ metric }}' as metric,
has_payment,
has_id_check,
main_billing_country_iso_3_per_deal,
'WTD' as timeframe,
sum(
case
when date_day between dr.current_week_start and {{ yesterday }}
then dm.{{ metric }}
end
) as current_value,
sum(
case
when date_day between dr.py_week_start and py_week_current_date
then dm.{{ metric }}
end
) as py_value,
sum(
case
when date_day between dr.pp_week_start and dr.pw_current_date
then dm.{{ metric }}
end
) as pp_value
from int_kpis__product_guest_daily_metrics dm, date_ranges dr
group by
metric, has_payment, has_id_check, main_billing_country_iso_3_per_deal
{% if not loop.last %}
union all
{% endif %}
{% endfor %}
)
select *
from aggregated_metrics