edgeLakeCodeQuery

Execute JavaScript programs server-side against Edge Lake event data for complex analysis that requires multiple queries, joins, aggregations, or funnel analysis.

Use dedicated analytics tools first (domainAnalytics, domainErrors, edgeLakeTrafficAnalysis) before falling back to Edge Lake queries. Use edgeLakeQuery for simple single queries. Use edgeLakeCodeQuery only when you need multi-step analysis.

Parameters

Parameter	Type	Required	Description
channelId	string (UUID)	Yes	The Edge Lake channel ID. Must be a channel with providerId: "edgeLake". Get this from the domains tool.
teamId	string (UUID)	Yes	The team ID the domain belongs to.
code	string	Yes	JavaScript code to execute server-side. Has access to codemode.query(sql) which returns { rows, meta }. Must return the final result.

Constraints

• Maximum 20 queries per execution
• 80-second timeout
• 100KB maximum result size
• Must return a final result (the last expression or explicit return)

API

Your code has access to:

• codemode.query(sql) - Execute an SQL query against lake.events. Returns { rows, meta }.
• Promise.all() - Run multiple queries in parallel.
• Standard JavaScript (no external libraries).

Examples

Conversion funnel

const [pageViews, addToCarts, checkouts, purchases] = await Promise.all([
  codemode.query(`SELECT COUNT(*) as count FROM lake.events WHERE event_name = 'PageView' AND event_timestamp BETWEEN '2024-01-01T00:00:00Z' AND '2024-01-07T23:59:59Z'`),
  codemode.query(`SELECT COUNT(*) as count FROM lake.events WHERE event_name = 'AddToCart' AND event_timestamp BETWEEN '2024-01-01T00:00:00Z' AND '2024-01-07T23:59:59Z'`),
  codemode.query(`SELECT COUNT(*) as count FROM lake.events WHERE event_name = 'InitiateCheckout' AND event_timestamp BETWEEN '2024-01-01T00:00:00Z' AND '2024-01-07T23:59:59Z'`),
  codemode.query(`SELECT COUNT(*) as count FROM lake.events WHERE event_name = 'Purchase' AND event_timestamp BETWEEN '2024-01-01T00:00:00Z' AND '2024-01-07T23:59:59Z'`)
]);

({
  funnel: [
    { step: 'PageView', count: pageViews.rows[0].count },
    { step: 'AddToCart', count: addToCarts.rows[0].count },
    { step: 'InitiateCheckout', count: checkouts.rows[0].count },
    { step: 'Purchase', count: purchases.rows[0].count }
  ]
})

Daily revenue trend

const result = await codemode.query(`
  SELECT event_timestamp, payload_value, payload_currency
  FROM lake.events
  WHERE event_name = 'Purchase'
    AND event_timestamp BETWEEN '2024-01-01T00:00:00Z' AND '2024-01-07T23:59:59Z'
  ORDER BY event_timestamp
  LIMIT 10000
`);

const dailyRevenue = {};
for (const row of result.rows) {
  const day = row.event_timestamp.split('T')[0];
  if (!dailyRevenue[day]) dailyRevenue[day] = 0;
  dailyRevenue[day] += Number(row.payload_value || 0);
}

Object.entries(dailyRevenue).map(([date, revenue]) => ({ date, revenue }));

Edge Lake Querying must be enabled for your domain. Contact [e-mail] if you get an "Action not permitted!" error.