PgQue – una cola para Postgres sin bloat

• Se instala con un solo archivo SQL y funciona (tick) solo con pg_cron
• Cola de mensajes integrada en Postgres que reimplementa la arquitectura PgQ de la era de Skype en PL/pgSQL puro, por lo que puede usarse directamente en Postgres administrado sin extensiones en C ni demonios externos
• Elimina de raíz los problemas crónicos de las colas con SKIP LOCKED —acumulación de dead tuples y carga de VACUUM— mediante lotes basados en snapshot + rotación de tablas con TRUNCATE, por lo que no hay degradación de rendimiento incluso tras meses de operación
• Estructura de log de eventos compartido + cursor independiente por consumidor similar a un tópico de Kafka, con soporte nativo para fan-out — múltiples suscriptores reciben todos los eventos de forma independiente sin replicar datos
• La latencia de entrega end-to-end es de ~1-2 segundos en la configuración predeterminada (intervalo de tick + intervalo de poll), y las llamadas individuales a send/receive/ack están en el nivel de microsegundos
• Según benchmarks preliminares: inserts en PL/pgSQL de ~86k ev/s, lectura de consumidores de ~2.4M ev/s, y cero aumento de dead tuples en una prueba continua de 30 minutos
• Al estar basado en API SQL como pgque.send(), pgque.receive(), pgque.ack(), funciona con cualquier driver de Postgres sin importar el lenguaje, como Python, Go o TypeScript
• Compatible con los principales proveedores de Postgres administrado como RDS, Aurora, Cloud SQL, AlloyDB, Supabase y Neon, sin necesidad de builds separados ni aprobación del proveedor
• Incluye separación de permisos basada en 3 roles (pgque_reader, pgque_writer, pgque_admin), sin requerir superuser para el usuario de la aplicación
• Aunque PgQ ya fue probado en producción durante más de 10 años a escala de cientos de millones de usuarios en Skype, PgQue como producto aún está en etapa temprana (v0.1)
• Licencia Apache-2.0