BEGIN; CREATE OR REPLACE FUNCTION process_raw_etsy_event() RETURNS TRIGGER AS $process_raw_etsy_event$ BEGIN INSERT INTO etsy_store_events ( platform, store_id, event_timestamp, event_id ) SELECT NEW.platform, NEW.store_id, NEW.event_timestamp, NEW.event_id; RETURN NULL; END; $process_raw_etsy_event$ LANGUAGE plpgsql; CREATE OR REPLACE TRIGGER etsy_store_events AFTER INSERT ON raw_store_events FOR EACH ROW WHEN (NEW.platform = 'etsy') EXECUTE FUNCTION process_raw_etsy_event(); COMMIT;