Attribution Pipeline Architecture
PTD ATTRIBUTION PIPELINE
============================================================================
META ADS SNOWPLOW STACK DATA STORES
-------- -------------- -----------
+----------------+ +--------------------+ +-------------------+
| Meta Lead Ads |---->| Snowplow Collector |--------->| Kafka (Warp) |
| (Native Forms) | | :8080 | | 3 topics |
+--------+-------+ +---------+----------+ +---------+---------+
| | |
v v v
+----------------+ +--------------------+ +-------------------+
| Meta Graph API | | Snowplow Enrich | | Bento (good) |
| /leads | | (schemas + enrich) | | Bento (bad) |
+--------+-------+ +---------+----------+ +---------+---------+
| | |
v v v
+----------------+ +--------------------+ +--------------------------+
| CVS Supabase | | atomic.events | | CVS Supabase |
| meta_leads | | (1,773 enriched) | | attribution_events |
| (902 leads) | | (1,051 bad) | | (7,275 events) |
+--------+-------+ +--------------------+ +--------------------------+
| |
+-----------------------------------------------------+
|
v
+--------------------+
| IDENTITY GRAPH |
| 444 edges |
| email = join key |
+---------+----------+
|
+------------+------------+
| | |
v v v
+-----------+ +-----------+ +-----------+
| HubSpot | | Hyros | | Leadpages |
| Portal | | (primary | | 9 pages |
| 7973797 | | attrib) | | tracked |
+-----------+ +-----------+ +-----------+
LEADPAGES -----> CVS Supabase (lp-track) -----> funnel_metrics (538)
============================================================================