Analyzer ingests enriched events

Analyzer consumes enriched-dev-events — RawEvent struct includes optional sentiment/risk_score.

playstepchallengeinstructor

step 1consumer.recv().await

step 2parse JSON → RawEvent

step 3persist_event(pool)

step 4warm_redis(client)

step 5auto-commit offset

StepReset

SELECT id, sentiment, risk_score, enriched_at FROM team_events ORDER BY created_at DESC LIMIT 3;

Teach-back prompt

How does radar Activity stream get risk badges?