snowplow_web_page_base.sql

with staged_events as (
    select * from  {{ ref('snowplow_events_base') }}
),

context as (

    select 
        event_id as root_id, 
        c.value:data:id::string as id,
        collector_tstamp
    from staged_events,
    lateral flatten (input => contexts:data) c
)

select * from context