29 lines
547 B
PL/PgSQL
29 lines
547 B
PL/PgSQL
BEGIN;
|
|
|
|
|
|
CREATE OR REPLACE FUNCTION process_raw_tiktok_event() RETURNS TRIGGER AS $process_raw_tiktok_event$
|
|
BEGIN
|
|
INSERT INTO tiktok_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_tiktok_event$ LANGUAGE plpgsql;
|
|
|
|
CREATE OR REPLACE TRIGGER tiktok_store_events
|
|
AFTER INSERT ON raw_store_events
|
|
FOR EACH ROW
|
|
WHEN (NEW.platform = 'tiktok')
|
|
EXECUTE FUNCTION process_raw_tiktok_event();
|
|
|
|
|
|
COMMIT;
|