Pubsub Python Packages

svix

The open source and enterprise-ready webhooks service 🦀

autobahn

WebSocket and WAMP in Python for Twisted and asyncio

aiomqtt

The idiomatic asyncio MQTT client

asyncio-mqtt

The idiomatic asyncio MQTT client

socketify

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

iceoryx2

Eclipse iceoryx2™ - the zero-copy data plane with a Rust core

fastapi-websocket-pubsub

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

fastapi-headless-wamp

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

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

event-channel

Tiny pub sub implentation

redis-message-queue

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

pymq

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

fastpubsub

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

pytest-streaming

Plugin for testing pubsub, pulsar, and kafka systems with pytest locally and in ci/cd

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, ...)

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

umik-base-app

Base framework and utilities for working with digital microphone in Python applications.

daebus

A lightweight framework for building Python background services with a Flask-like API, enabling seamless inter-service communication via Redis pub/sub.

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.