Media & Gaming
Event pipelines and content metrics at scale. Unify streaming and batch data without moving a single event row.
Executive summary
Connect stream + warehouse metadata into Metroflow. Certify DAU and watch-time in 60 days. Gate every schema change on blast-radius checks.
Media and gaming teams lose hours reconciling engagement numbers and hunting stale dashboards after Flink failures. Metroflow gives every team one searchable map of how live events flow into reports, with certified metrics and proof.
What broken lineage costs you
Typical patterns at streaming and gaming companies. Ranges, not guarantees.
Stream job fails at 3am
2–6 hours of Slack archaeology
With Metroflow: Blast-radius query in minutes. Stakeholders notified before standup.
DAU defined five ways
1–3 hours per exec review reconciling
With Metroflow: One certified metric ID. Rogue explores flagged.
Session model change
Surprise breakages in ML or board decks
With Metroflow: Pre-merge impact across streams, warehouse, and BI.
New analyst onboarding
2–3 weeks to first trusted lineage query
With Metroflow: Living graph day one. Company Brain in plain English.
Metadata only. Metroflow crawls schemas, job names, manifests, and dashboard definitions. Your video, gameplay, and event rows never leave your network.
Your stack, one graph
Live events and overnight batch jobs connected. Metroflow sits above the data path, not inside it.
When sessionize_stream fails, trace the blast radius: staging tables stop updating → dbt models break → Looker explores and board slides go stale. One query, full picture.
Where are you today?
Most teams land at L1 or L2. Target L4 in 90 days.
Quick self-check
- Trace DAU from dashboard tile to Kafka topic in under 5 minutes?
- Growth and content share one definition of "active user"?
- Flink failure → affected dashboards without opening Slack?
- dbt PRs include cross-layer impact checks?
- Named owner for watch-time and DAU?
0–2: Start Week 1 connect · 3–4: Certify metrics · 5: Add change gates
Choose your path
Media & gaming is not one stack. Pick the track closest to your business.
Mobile & PC gaming
Events: match_started, level_complete, purchase
Certify first: DAU, D1/D7 retention, session length, ARPDAU
Streaming & VOD
Events: episode_start, watch_heartbeat, subscribe
Certify first: Watch-time, concurrent viewers, completion rate
Live & esports
Events: stream_join, chat_message, concurrent_viewers
Certify first: Peak concurrency, avg watch, engagement rate
Who owns what
DAU fights are governance problems. Assign decision rights up front.
| Role | Owns | On Metroflow |
|---|---|---|
| Data platform | Kafka, Flink, Airflow | Register jobs. Blast-radius on failure. Own comms template. |
| Analytics engineer | dbt models, session logic | Impact before PR merge. Link models to topics. |
| BI lead | Looker, exec dashboards | Certified metrics only. Deprecate rogue SQL. |
| Growth / content | Metric definitions | Approve DAU and watch-time. Self-serve via Brain. |
| Head of data | Certification sign-off | Gate changes. Weekly trust score on dashboards. |
30 · 60 · 90 day rollout
A program with gates, not just a connector checklist.
Connect & first win
- Connect warehouse, dbt, orchestration, BI
- Register Kafka topics + Flink jobs
- First blast-radius query
Certify metrics
- Publish DAU + watch-time specs
- Migrate top 5 dashboards
- Flag legacy explores
Operationalize
- Pre-merge impact for session models
- 3am runbook in on-call
- Weekly stale-dashboard report
3am incident runbook
sessionize_stream is failing. Follow this timeline.
Flink retrying or lag spiking. Open Metroflow, search job name.
Paste Slack template below. Tag BI lead and content ops.
Restart, scale, or rollback Flink. Analytics monitors freshness.
Re-run lineage. Close with affected dashboard list.
Slack template
Metric certification pack
Copy into your governance doc. One definition. One owner. Full lineage.
DAU (Daily Active Users)
Certify first- Formula
- Distinct user_id with ≥1 qualifying event per calendar day (UTC).
- Event
session_startORmatch_startedORepisode_start
- Exclusions
- Bots, test accounts, sessions < 5 seconds.
- Owner
- Head of Growth + Analytics Eng
- Lineage
raw_play_events→sessionize_stream→fct_dau→ Exec dashboard
Watch-time (minutes)
Certify second- Formula
- Sum of
watch_heartbeatintervals, 5 min gap cap.
- Edge cases
- Exclude background play after 60s idle. Pause > 3 min stops count.
- Owner
- Content analytics + Analytics Eng
- Lineage
watch_heartbeat→fct_watch_time→ Content Performance
Session engagement rate
Certify third- Formula
- % sessions with ≥2 meaningful events OR duration ≥3 min.
- Why
- Separates passive opens from real engagement. Stops DAU inflation.
- Owner
- Product analytics + Growth
Daily workflows
Four situations you will hit every week.
Monday content review
- Check freshness
Stale explores from weekend stream lag?
- Certified metrics
Content Performance on watch-time ID?
- Ask Brain
Pipeline delay or definition change?
Before a dbt PR
- Impact query
Renamed columns in session models.
- Notify BI
If certified explore affected.
- Attach diff
Lineage diff in PR description.
DAU dispute
- Open spec
Formula, exclusions, owner.
- Trace lineage
Dashboard tile → source topic.
- Flag rogues
Migrate explores off legacy SQL.
Content launch
- Verify schema
Event catalog before launch day.
- Pre-wire dashboard
Certified engagement metrics.
- Baseline
7-day watch-time for before/after.
Copy-paste queries
Company Brain or lineage search. Context included.
Glossary
Plain English. "Why it matters" tells you when to care.
Outcomes checklist
Measure if the program is working.
| Success metric | 90-day target |
|---|---|
| Time to answer "what breaks if X fails?" | < 15 minutes |
| Exec dashboards on certified DAU | 100% of top 5 |
| Cross-team DAU escalations / month | Near zero |
| Surprise stale metrics in reviews | Zero |
Ready to unify your stack?
Week 1: connect and run your first blast-radius query. Week 4: certify DAU. Week 8: operationalize the runbook.