Pubsub Python Packages

autobahn

WebSocket and WAMP in Python for Twisted and asyncio

aiomqtt

The idiomatic asyncio MQTT client

asyncio-mqtt

The idiomatic asyncio MQTT client

fastapi-websocket-pubsub

A fast and durable Pub/Sub channel over Websockets. FastAPI + WebSockets + PubSub == ⚡ 💪 ❤️

socketify

Bringing Http/Https and WebSockets High Performance servers for PyPy3 and Python3

mqtt5

The MQTTv5 protocol for Python written in Rust

repid

Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation

rele

Easy to use Google Pub/Sub

iceoryx2

Eclipse iceoryx2™ - true zero-copy inter-process-communication with a Rust core

pytest-streaming

PyTest plugin for enabling stream-lined testing of pubsub, pulsar, kafka, and nats

opal-common

Policy and data administration, distribution, and real-time updates on top of Policy Agents (OPA, Cedar, ...)

opal-client

Policy and data administration, distribution, and real-time updates on top of Policy Agents (OPA, Cedar, ...)

pymq

A simple message-oriented middleware library built for Python IPC across machine boundaries

fastpubsub

FastPubSub: A high-performance, asyncio-native framework for Google Cloud Pub/Sub applications

opal-server

Policy and data administration, distribution, and real-time updates on top of Policy Agents (OPA, Cedar, ...)

fastapi-headless-wamp

Full bidirectional WAMP RPC and PubSub for FastAPI without a separate WAMP router

event-channel

Tiny pub sub implentation

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.

awsgreengrasspubsubsdk

AWS IoT Greengrass PubSub SDK for Python

ytnoti

Easy-to-use Python library for receiving real-time YouTube push notifications for video uploads, edits, deletions, and live streams.

celery-connectors

Want to handle 100,000 messages in 90 seconds? Celery and Kombu are that awesome - Multiple publisher-subscriber demos for processing json or pickled messages from Redis, RabbitMQ or AWS SQS. Includes Kombu message processors using native Producer and Consumer classes as well as ConsumerProducerMixin workers for relay publish-hook or caching

synap-sdk

Synap is a modern, high-performance data infrastructure system built in Rust, combining the best features of Redis, RabbitMQ, and Kafka into a unified platform for real-time applications.

market-data-transcoder

ffmpeg for market data

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.