pgmq

What it is for

pgmq is a lightweight queue built on tables. A reader takes messages with a visibility timeout; if it crashes, the message becomes visible again after the timeout. Delete or archive a message once it is handled. Because it is Postgres, enqueueing can be part of the same transaction as the write that caused it.

Enable it

create extension if not exists pgmq;

Example

select pgmq.create('emails');

select pgmq.send('emails', '{"to": "ana@example.com", "template": "welcome"}');

-- take up to 5 messages, hidden from other readers for 30 seconds
select msg_id, message from pgmq.read('emails', 30, 5);

select pgmq.archive('emails', 1);

Questions

Upstream project: github.com/pgmq/pgmq

More jobs, queues and partitions extensions

• pg_cron Run SQL on a schedule written in cron syntax.
• pg_partman Create and drop time or number partitions for you.