drob

CREATE TABLE event (
  user_id BIGINT,
  event_id BIGINT,
  time BIGINT NOT NULL,
  data JSON NOT NULL,
  PRIMARY KEY (user_id, event_id)
)

drob

SELECT
  nspname,
  relname,
  dead_tuples,
  autovacuum_threshold,
  dead_tuples > autovacuum_threshold AS overdue
FROM (
  SELECT
    nspname,
    relname,

drob

SELECT remainder, array_agg(i)
FROM (
  SELECT i % 2 AS remainder, i
  FROM generate_series(1, 10) AS i
  ORDER BY i
) nums 
GROUP BY remainder;

drob

SELECT array_agg(i)
FROM (
  SELECT i
  FROM generate_series(1, 10) AS i
  ORDER BY i
) nums;

drob

CREATE OR REPLACE FUNCTION does_not_blowup(num BIGINT) RETURNS HSTORE[] AS $$
  SELECT array_agg(('num=>' || i)::HSTORE)
  FROM generate_series(1, num) AS i;
$$ LANGUAGE SQL IMMUTABLE;

drob

#!/usr/bin/env ruby

num_events = ARGV[0].to_i

@rng = Random.new
def rand_id
  @rng.rand 0...1000
end

def rand_data

drob

-- Filter an array of events such that there is only one event with each event_id.
-- When more than one event with the same event_id, is present, take the latest one.
CREATE OR REPLACE FUNCTION dedupe_events_2(events HSTORE[]) RETURNS HSTORE[] AS $$
  SELECT array_agg(event)
  FROM (
    -- Filter for rank = 1, i.e. select the latest event for any collisions on event_id.
    SELECT event
    FROM (
      -- Rank elements with the same event_id by position in the array, descending.
      SELECT event, row_number AS index, rank()

drob

-- This is slow, and you don't want to use it!
--
-- Filter an array of events such that there is only one event with each event_id.
-- When more than one event with the same event_id is present, take the latest one.
CREATE OR REPLACE FUNCTION dedupe_events_1(events HSTORE[]) RETURNS HSTORE[] AS $$
  SELECT array_agg(event)
  FROM (
    -- Filter for rank = 1, i.e. select the latest event for any collisions on event_id.
    SELECT event
    FROM (

drob

CREATE OR REPLACE FUNCTION blowup(num BIGINT) RETURNS HSTORE[] AS $$
DECLARE
  result HSTORE[] := '{}';
  i BIGINT;
BEGIN
  FOR i IN 1..num LOOP
    result := array_append(result, ('num=>' || i)::HSTORE);
  END LOOP;

  RETURN result;

drob

---
- name: Register New Relic repository.
  get_url: url=http://download.newrelic.com/debian/newrelic.list
           dest=/etc/apt/sources.list.d/newrelic.list

- name: Download repo key.
  apt_key: url=http://download.newrelic.com/548C16BF.gpg

- name: Install New Relic.
  apt: pkg=newrelic-sysmond update_cache=yes