Get Started
Whether you're building AI agents or analytics pipelines, everything you need to get running is here.
Track behavioral events. Fetch live user context in <10ms. Build smarter AI agents and advanced analytics - all from one trusted data layer.
count_product_views = Attribute(
name="count_product_views",
type="int32",
events=[Event(name="snowplow_ecommerce_action")],
criteria=Criteria(
all=[
Criterion.eq(
property=EventProperty(
vendor="com.snowplowanalytics.snowplow.ecommerce",
name="snowplow_ecommerce_action",
major_version=1,
path="type",
),
value="product_view",
)
]
),
aggregation="counter",
)
attribute_group = StreamAttributeGroup(
name="ecom_attributes",
version=1,
attribute_key=domain_userid,
attributes=[
count_product_views,
count_add_to_cart,
total_cart_value,
],
owner="user@company.com",
)
stream_service = Service(
name="ecom_attributes",
attribute_groups=[attribute_group],
owner="user@company.com",
)
// JavaScript tracker
snowplow('trackSelfDescribingEvent', {
event: {
schema: 'iglu:com.yourcompany/conversion/jsonschema/1-0-0',
data: {
conversion_type: 'signup',
plan: 'pro'
}
}
});
# packages.yml
packages:
- package: snowplow/snowplow_unified
version: [">=0.5.0", "<2.0.0"]
dbt deps
dbt run --select snowplow_unified
SELECT
session_identifier,
engaged_time_in_s,
views_in_session,
first_page_title
FROM <target_schema>_derived.snowplow_unified_sessions
ORDER BY start_tstamp DESC
LIMIT 10;




.png)



.png)



Whether you're building AI agents or analytics pipelines, everything you need to get running is here.