diff --git a/models/core/fct_lap_times.sql b/models/core/fct_lap_times.sql new file mode 100644 index 0000000..607269b --- /dev/null +++ b/models/core/fct_lap_times.sql @@ -0,0 +1,13 @@ +with lap_times as ( + select + {{ dbt_utils.generate_surrogate_key(['race_id', 'driver_id', 'lap']) }} as lap_times_id, + race_id as race_id, + driver_id as driver_id, + lap as lap, + driver_position as driver_position, + lap_time_formatted as lap_time_formatted, + official_laptime as official_laptime, + lap_time_milliseconds as lap_time_milliseconds + from {{ ref('stg_lap_times') }} +) +select * from lap_times \ No newline at end of file diff --git a/models/marts/mrt_lap_times_years.sql b/models/marts/mrt_lap_times_years.sql new file mode 100644 index 0000000..16decb0 --- /dev/null +++ b/models/marts/mrt_lap_times_years.sql @@ -0,0 +1,19 @@ +with lap_times as ( +select * from {{ ref('fct_lap_times') }} + ), + races as ( + select * from {{ ref('dim_races') }} + ), + expanded_lap_times_by_year as ( + select + lap_times.race_id, + driver_id, + race_year, + lap, + lap_time_milliseconds + from lap_times + left join races + on lap_times.race_id = races.race_id + where lap_time_milliseconds is not null + ) + select * from expanded_lap_times_by_year \ No newline at end of file