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

rele

Easy to use Google Pub/Sub

repid

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

mqtt5

The MQTTv5 protocol for Python written in Rust

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

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.

event-channel

Tiny pub sub implentation

opal-common

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

fastapi-headless-wamp

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

umik-base-app

Audio Base App and Framework

fastpubsub

FastPubSub is a asyncio-native, high-performance, and easy-to-use Python framework for building asynchronous event stream consumers on Google PubSub.

opal-client

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

opal-server

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

awsgreengrasspubsubsdk

AWS IoT Greengrass PubSub SDK for Python

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

ytnoti

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

pynnex

A Python Emitter-Listener library

centrifuge

Simple real-time messaging in web applications