Message Broker Python Packages

aioconnectors

Simple secure asynchronous message queue

4K 21 3

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.

3K 5 1

lorrystream

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

2K 6 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

2K 31 13

brokrpc

framework for gRPC like server-client communication over message brokers

860 4 0

loafer

Asynchronous message dispatcher - Currently using asyncio and amazon SQS

657 110 23

memphis-py

Python client for Memphis. Memphis is an event processing platform

630 38 22

memphis-py-beta

Python client for Memphis. Memphis is an event processing platform

484 38 22

payler

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

456 5 0

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.

407 2 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

390 74K 25K

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.

306 84 1