Python SDK

The KubeMQ Python SDK provides async clients for all messaging patterns. It requires Python 3.9+ and communicates with KubeMQ over gRPC.

Installation

pip install kubemq

For optional features:

pip install kubemq[otel]    # OpenTelemetry integration

Quick connect

from kubemq import AsyncPubSubClient

# Connect to a local KubeMQ server on the default gRPC port.
async with AsyncPubSubClient(address="localhost:50000") as client:
    ...

Next: send your first message

With the SDK installed, continue to the first-message tutorial to connect a client and publish and receive your first message.