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

removed macro and kept all logic inside the model

Browse source
This commit is contained in:
Joaquin 2025-04-02 12:01:57 +02:00
parent 78e2474a87
commit ab179577b1
15 changed files with 52 additions and 53 deletions
Download patch file Download diff file Expand all files Collapse all files

4
models/intermediate/kpis/int_kpis__agg_daily_new_dash_accommodation_offered_services.sql
View file

@ -1,4 +1,6 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model(
"NEW_DASH_ACCOMMODATION_OFFERED_SERVICES"
) %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_daily_new_dash_chargeable_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CHARGEABLE_SERVICES") %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_daily_new_dash_created_bookings.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_BOOKINGS") %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_daily_new_dash_created_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_SERVICES") %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

4
models/intermediate/kpis/int_kpis__agg_monthly_new_dash_accommodation_offered_services.sql
View file

@ -1,4 +1,6 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model(
"NEW_DASH_ACCOMMODATION_OFFERED_SERVICES"
) %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_monthly_new_dash_chargeable_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CHARGEABLE_SERVICES") %}
{{
config(

2
models/intermediate/kpis/int_kpis__agg_monthly_new_dash_created_bookings.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_BOOKINGS") %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_monthly_new_dash_created_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_SERVICES") %}
{{
config(

4
models/intermediate/kpis/int_kpis__agg_weekly_new_dash_accommodation_offered_services.sql
View file

@ -1,4 +1,6 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model(
"NEW_DASH_ACCOMMODATION_OFFERED_SERVICES"
) %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_weekly_new_dash_chargeable_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CHARGEABLE_SERVICES") %}
{{
config(

2
models/intermediate/kpis/int_kpis__agg_weekly_new_dash_created_bookings.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_BOOKINGS") %}
{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

2
models/intermediate/kpis/int_kpis__agg_weekly_new_dash_created_services.sql
View file

@ -1,4 +1,4 @@
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH") %}
{% set dimensions = get_kpi_dimensions_per_model("NEW_DASH_CREATED_SERVICES") %}
{{
config(

35
models/intermediate/kpis/int_kpis__product_new_dash_agg_metrics.sql
View file

@ -119,11 +119,30 @@ with
left join int_kpis__dimension_dates d on c.date = d.date
)
select *
from ({{ generate_kpis_aggregation("daily", agg_models) }})
union all
select *
from ({{ generate_kpis_aggregation("weekly", agg_models) }})
union all
select *
from ({{ generate_kpis_aggregation("monthly", agg_models) }})
{% for time_granularity in ["daily", "weekly", "monthly"] %}
{% if time_granularity != "daily" %}
union all
{% endif %}
select
d.date,
'{{ time_granularity }}' as time_granularity,
d.dimension,
d.dimension_value
{% for agg_model in agg_models if time_granularity in agg_model["name"] %}
{% for metric in agg_model["metrics"] %}
, coalesce({{ ref(agg_model["name"]) }}.{{ metric }}, 0) as {{ metric }}
{% endfor %}
{% endfor %}
from all_dates d
{% for agg_model in agg_models if time_granularity in agg_model["name"] %}
left join
{{ ref(agg_model["name"]) }}
on d.date = {{ ref(agg_model["name"]) }}.{{ agg_model["date_field"] }}
and d.dimension = {{ ref(agg_model["name"]) }}.dimension
and d.dimension_value = {{ ref(agg_model["name"]) }}.dimension_value
{% endfor %}
{% if time_granularity == "weekly" %} where d.is_end_of_week
{% elif time_granularity == "monthly" %} where d.is_end_of_month
{% endif %}
{% endfor %}