Message Broker Python Packages

aioconnectors

Simple secure asynchronous message queue

2K 21 3

queen-mq

High-performance transactional message broker for applications that need an ordered stream per entity.

2K 50 5

redis-message-queue

Lightweight Python message queuing with Redis and built-in publish-side deduplication.

2K 5 1

mx-multiplexer

Lightweight, stateless message broker for request/reply and publish/subscribe between services on a trusted internal network. Declarative routing rules: round-robin load balancing, fan-out, direct addressing. C++17 core, C++ and Python client libraries, active-active redundancy. In production since 2008.

2K 1 0

infinity-bus

Middleware-native async event bus — extensible, type-safe, one dependency.

2K 1 0

stopover-server

A simple and robust message broker built on top of RocksDB

767 4 1

lorrystream

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

631 6 0

chasquimq

ChasquiMQ is a Redis-backed message broker / background job queue

600 16 1

brokrpc

framework for gRPC like server-client communication over message brokers

593 4 0

b-rabbit

A thread safe library that aims to provide a simple API for interfacing with RabbitMQ. Built on top of rabbitpy, the library make it very easy to use the RabbitMQ message broker with just few lines of code. It implements all messaging pattern used by message brokers

591 32 13

loafer

Asynchronous message dispatcher - Currently using asyncio and amazon SQS

565 110 23

memphis-py

Python client for Memphis. Memphis is an event processing platform

375 38 21

memphis-py-beta

Python client for Memphis. Memphis is an event processing platform

310 38 21

django-action-triggers

A Django library for asynchronously triggering actions in response to database changes. It supports integration with webhooks, message brokers (e.g., Kafka, RabbitMQ), and can trigger other processes, including AWS Lambda functions.

299 85 1

booblik

Message broker in Kotlin/JVM on an append-only log: partitions, segments and consumer-held offsets, with everything a cluster needs deliberately absent

242 0 1

redisex

For developers, who are building real-time data-driven applications, Redis is the preferred, fastest, and most feature-rich cache, data structure server, and document and vector query engine.

238 77K 25K

syslogng-kafka

syslogng_kafka provides a Python module for syslog-ng 3.7 allowing one to filter and forward syslog messages to Apache Kafka brokers.

216 2 1

django-faktory-outbox

Python package that implements the Transactional Outbox Pattern for Django and Faktory. It acts as a reliable relay between your web application and the message broker, ensuring 100% data integrity by staging background jobs inside the primary database transaction to prevent orphaned or duplicate tasks during network splits or broker down

120 0 0