Example of a Postgres rollup

rollup.sql

CREATE OR REPLACE FUNCTION compute_5min_rollups(start_time TIMESTAMP, end_time TIMESTAMP)
RETURNS void LANGUAGE PLPGSQL AS $function$
BEGIN
 EXECUTE $$
   INSERT INTO rollups_5min
   SELECT
      date_trunc('seconds', (timestamp - TIMESTAMP 'epoch') / 300) * 300 + TIMESTAMP 'epoch' AS minute,
      app_id,
      timestamp,
      count(*) AS query_count,
      hll_add_agg(hll_hash_bigint(user_id)) AS user_count,
      topn_add_agg(query) AS top_queries
   FROM queries
   WHERE timestamp >= $1 AND timestamp <= $2
   GROUP BY app_id, minute; $$
 USING start_time, end_time;
END;
$function$