Message Broker Python Packages

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.

6K 5 1

aioconnectors

Simple secure asynchronous message queue

5K 21 3

chasquimq

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

4K 12 1

b-rabbit

An abstract interface for RabbitMQ communication

2K 31 13

lorrystream

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

1K 6 0

brokrpc

framework for gRPC like server-client communication over message brokers

871 4 0

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

645 0 0

loafer

Asynchronous message dispatcher - Currently using asyncio and amazon SQS

560 110 23

memphis-py

Python client for Memphis. Memphis is an event processing platform

533 38 22

payler

Temporize job execution, delay messages without asking your broker too much.

434 5 0

memphis-py-beta

A powerful messaging platform for modern developers

366 38 22

syslogng-kafka

syslog-ng mod-python Kafka driver

330 2 1

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.

310 84 1

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

288 74K 25K