Function routeEvent

packages/stats/server/src/ingest.ts:145–153

(event: IngestEvent)

}

function routeEvent(event: IngestEvent): LakeRoute | undefined {
  if (typeof event._datalake_key !== "string") return
  const match = event._datalake_key.match(LAKE_TYPE)
  if (!match?.[1] || !match[2]) return
  return {
    database: match[1],
    table: match[2],
  }
}

function toFirehoseRecord(event: IngestEvent, route: LakeRoute): FirehoseRecord {
  return {