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

iceoryx2

Eclipse iceoryx2™ - true zero-copy inter-process-communication 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

event-channel

Tiny pub sub implentation

repid

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

streamcast

A JSON WebSocket pubsub framework for structured data.

socketify

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

pytest-streaming

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

pymq

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

oxbrook

A fast Python REST framework with a Rust core, built-in reactive streams, and agent-native interfaces

mqtt5

The MQTTv5 protocol for Python written in Rust

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

plasmite

Easy interprocess communication based on persistent JSON message queues

queen-mq

High-performance transactional message broker for applications that need an ordered stream per entity.

redis-message-queue

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

mx-multiplexer

Lightweight, stateless message broker for request/reply and publish/subscribe between services on a trusted internal network. Declarative routing rules: round-robin load balancing, fan-out, direct addressing. C++17 core, C++ and Python client libraries, active-active redundancy. In production since 2008.

chattice

Async typed event framework for Google Chat apps