Search Packages

kombu

Messaging library for Python.

saq

Simple Async Queues

tembo-pgmq-python

A lightweight message queue. Like AWS SQS and RSMQ but on Postgres.

django-pgpubsub

A distributed task processing framework for Django built on top of the Postgres NOTIFY/LISTEN protocol.

aioconnectors

Simple secure asynchronous message queue

redis-message-queue

Reliable Python message queuing with Redis and built-in deduplication. Publish once, process once, recover from crashes - across any number of producers and consumers.

mpmq

A lightweight multiprocessing framework that executes functions across worker processes while routing log messages through a central queue.

lorrystream

A lightweight and polyglot stream-processing library, to be used as a data backplane-, message relay-, or pipeline-subsystem.

pgmq-sqlalchemy

More flexible PGMQ Postgres extension Python client that using SQLAlchemy ORM, supporting both async and sync engines, sessionmakers or built from dsn.

asyncmq

Supercharge your async applications with tasks so fast, you’ll think you’re bending time itself.

fastq-redis

Python bindings for FastQ — high-performance Redis job queue written in C

brokrpc

framework for gRPC like server-client communication over message brokers

asbflow

ASBFlow is a high-level Python abstraction over Microsoft Azure Service Bus, providing clean APIs for publish/consume workflows, DLQ management, parsing, and execution strategies.

queen-mq

Partitioned Message Queue backed by PostgreSQL

aio-pika-batch

Batch consumer for aio-pika with per-message ACK/NACK/REQUEUE, retry tracking, dead-letter routing, and multi-worker scaling. The missing batch layer for RabbitMQ in Python.

plasmite

Persistent JSON message queues for Python - native bindings for local and remote IPC

fastsqs

FastAPI-like, modern SQS message processing for Python with advanced features

aiosafeconsumer

Safely consume and process data.

easyjobs

A celery like jobs framework for managing and distributing async / non-async tasks

asvmq

ASV Messaging Queue for the Year 2019

rhubarb-py

An Event Bus library that simplifies interacting with multiple queue backends into a single API

abe-redis

📮 A Redis-based abstracted backend (abe) for abstract backend message queue.

redisex

Redis is an open source (BSD licensed), in-memory data structure store, used as a database, cache, and message broker. Redis provides data structures such as strings, hashes, lists, sets, sorted sets with range queries, bitmaps, hyperloglogs, geospatial indexes, and streams. Redis has built-in replication, Lua scripting, LRU eviction, transactions, and different levels of on-disk persistence, and provides high availability via Redis Sentinel and automatic partitioning with Redis Cluster

kombuzstest

Messaging library for Python.