Message Queue Python 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.

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.

lorrystream

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

fastq-redis

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

queen-mq

Partitioned Message Queue backed by PostgreSQL

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.

brokrpc

framework for gRPC like server-client communication over message brokers

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

aiosafeconsumer

Safely consume and process data.

fastsqs

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

rhubarb-py

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

easyjobs

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

asvmq

ASV Messaging Queue for the Year 2019

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

monqueue

MonQueue is a Python library that allows you to use MongoDB as a message queue