3 repositorios
Job orchestrators that utilize PostgreSQL for persistence, transactional enqueuing, and state management.
Distinct from PostgreSQL Adapters: This is an identity for the whole system as a queue, not just a database adapter or migration tool.
Explore 3 awesome GitHub repositories matching data & databases · PostgreSQL Task Queues. Refine with filters or upvote what's useful.
River es una cola de trabajos transaccional y programador de trabajos distribuido para Go que utiliza PostgreSQL para la persistencia y gestión de estado. Funciona como un framework de tareas reanudables, permitiendo que el trabajo en segundo plano de larga duración se divida en pasos persistidos que pueden reanudarse desde el último punto de control guardado después de un fallo. El sistema asegura una estricta consistencia de datos permitiendo que las tareas en segundo plano sean encoladas y completadas dentro de la misma transacción de base de datos que los datos principales de la aplicación. Se distingue por un modelo de coordinador que emplea elección de líder para gestionar tareas periódicas y retrasadas a través de un clúster de nodos trabajadores. La plataforma cubre un amplio conjunto de capacidades, incluyendo procesamiento de tareas asíncronas, configuración de políticas de reintento con retroceso exponencial y aislamiento de carga de trabajo a través de colas con nombre. También proporciona herramientas para monitoreo mediante una interfaz de gestión web, telemetría de ejecución y un sistema de middleware para inyectar preocupaciones transversales como el registro (logging). Las migraciones de esquema de base de datos pueden gestionarse a través de una interfaz de línea de comandos o directamente mediante código.
Uses PostgreSQL as the primary engine for job persistence, transactional enqueuing, and state management.
PGMQ es un sistema de cola de mensajes ligero implementado como una extensión de PostgreSQL para gestionar tareas asincrónicas. Funciona como un intermediario de mensajes respaldado por base de datos que aprovecha PostgreSQL para almacenamiento persistente, operaciones atómicas y entrega impulsada por notificaciones. El sistema proporciona un modelo de cola compatible con SQS que cuenta con tiempos de espera de visibilidad y entrega retrasada. Admite un orden estricto de primero en entrar, primero en salir (FIFO) a través de claves de grupo y recuperación por lotes para garantizar el procesamiento secuencial de tareas relacionadas. El proyecto cubre un ciclo de vida completo de mensajes, incluyendo producción, consumo mediante operaciones pop atómicas y gestión administrativa como purga de colas y control del ciclo de vida. Incluye capacidades de enrutamiento a través de patrones basados en temas y características de confiabilidad como colas de mensajes fallidos (dead letter queueing), archivo de mensajes y lógica de reintento. Se proporcionan herramientas de monitoreo para rastrear métricas operativas como la longitud de la cola y el rendimiento.
Provides a lightweight message queuing system implemented as a PostgreSQL extension to manage asynchronous tasks.
Queue Classic es un framework de procesamiento en segundo plano para aplicaciones Ruby que gestiona tareas asíncronas utilizando tablas de bases de datos relacionales para la persistencia de trabajos. Al almacenar tareas directamente dentro de la base de datos, el sistema asegura que la creación de trabajos permanezca acoplada con las transacciones de la aplicación, garantizando que las tareas solo se pongan en cola cuando los cambios de datos asociados se confirmen (commit) con éxito. El framework coordina procesos de trabajo concurrentes a través de mecanismos de bloqueo a nivel de base de datos, que evitan la ejecución redundante y permiten el procesamiento de tareas distribuidas sin necesidad de un broker de mensajes externo. Los trabajadores operan sondeando la base de datos en busca de trabajos pendientes, admitiendo tanto la ejecución inmediata como la programación retrasada basada en marcas de tiempo futuras. El sistema proporciona un mecanismo para descargar operaciones que consumen mucho tiempo del hilo principal de la aplicación a procesos de trabajo independientes. Admite configuraciones de manejadores personalizados, permitiendo a los desarrolladores definir lógica específica para tareas en segundo plano mientras mantienen la consistencia a través del almacenamiento relacional subyacente.
Manages asynchronous tasks by leveraging PostgreSQL tables for reliable persistence and transactional queuing.