Client

The Python SDK ships pattern-specific async clients. AsyncPubSubClient handles Events and Events Store, AsyncQueuesClient handles Queues, and AsyncCQClient handles Commands and Queries. All accept the same constructor options and work as async context managers.

Package

pip install kubemq

Requires Python 3.9+.

Client classes

Constructor (illustrative)

AsyncPubSubClient(
    address: str = "localhost:50000",
    client_id: str | None = None,
    auth_token: str | None = None,
    ...
)

Parameters:

Returns: Client instance (connect via async with or await client.connect()).

Throws: KubeMQError subclasses — connection, validation, or auth failures.

Note: Pass AsyncCancellationToken objects into long-running subscriptions to stop workers cooperatively.

Context managers

async with AsyncPubSubClient(address="localhost:50000") as client:
    ...

Quick Usage

import asyncio
from kubemq import AsyncPubSubClient

async def main():
    async with AsyncPubSubClient(address="localhost:50000", client_id="py-demo") as client:
        await client.ping()

asyncio.run(main())

See Also

• Connection Examples
• Concepts
• Python SDK Getting Started