按事件名稱測量 Telemetry 音量

SELECT
  event_name,
  source,
  COUNT(*) AS events,
  SUM(payload_bytes) AS total_payload_bytes,
  AVG(payload_bytes) AS avg_payload_bytes,
  SUM(CASE WHEN accepted THEN 0 ELSE 1 END) AS rejected_events,
  100.0 * SUM(CASE WHEN accepted THEN 0 ELSE 1 END)
    / NULLIF(COUNT(*), 0) AS rejection_rate_pct
FROM telemetry_ingestion_events
WHERE timestamp_utc >= now() - INTERVAL '24 hours'
  AND environment = 'production'
GROUP BY event_name, source
ORDER BY total_payload_bytes DESC, event_name;