PGMQ

Was ist PGMQ?

PGMQ (Postgres Message Queue) ist eine Erweiterung fuer PostgreSQL, die eine einfache, SQL-basierte Message-Queue direkt in der Datenbank implementiert. Entwickelt von Tembo, ermoeglicht PGMQ das Senden, Empfangen und Verwalten von Nachrichten ohne externe Messaging-Systeme wie RabbitMQ oder Redis. Fuer Teams, die bereits PostgreSQL als Datenbank betreiben, bietet PGMQ eine schlanke Moeglichkeit, einfache Queue-Funktionalitaet hinzuzufuegen.

SQL-basierte Queue-Operationen

PGMQ stellt SQL-Funktionen bereit: pgmq.send() schreibt Nachrichten in die Queue, pgmq.read() liest und sperrt Nachrichten fuer eine konfigurierbare Sichtbarkeitszeit (Visibility Timeout), und pgmq.delete() bestaetigt die erfolgreiche Verarbeitung. Das Visibility-Timeout-Modell -- wie bei Amazon SQS -- stellt sicher, dass Nachrichten bei Consumer-Ausfaellen erneut zugestellt werden. Nachrichten werden als JSONB gespeichert, was eine flexible Payload-Struktur ermoeglicht.

PGMQ vs. Redis Queues und RabbitMQ

Redis-basierte Queues (z.B. mit BullMQ) bieten hoehere Durchsatzraten, fuehren aber eine zusaetzliche Infrastrukturkomponente ein. RabbitMQ ist fuer komplexe Routing-Szenarien und hohen Nachrichtendurchsatz optimiert, benoetigt aber eigene Administration. PGMQ ist die richtige Wahl, wenn einfache Queue-Anforderungen bestehen und kein zusaetzlicher Infrastrukturaufwand gewuenscht ist. Die Transaktionssicherheit von PostgreSQL ist dabei ein wesentlicher Vorteil.

PGMQ in Produktionsumgebungen

PGMQ laesst sich per PGXN oder als Docker-Image deployen und ist in Sekunden einsatzbereit. Fuer Anwendungen mit maessigem Message-Throughput -- wie Background-Job-Queues, Email-Sending-Queues oder Webhook-Delivery-Systeme -- ist PGMQ eine pragmatische Loesung. Die volle ACID-Compliance von PostgreSQL stellt sicher, dass keine Nachrichten verloren gehen, auch wenn die Anwendung waehrend der Verarbeitung abstuerzt.