Client SDKsPythonReference
Events Store
Durable events with replay — KubeMQ Python SDK reference.
Use send_event_store for persisted events and subscribe_to_events_store with EventsStoreSubscription to control replay semantics.
send_event_store
await client.send_event_store(message: EventStoreMessage) -> EventStoreResultReturns: EventStoreResult — broker acknowledgement payload.
subscribe_to_events_store
async for event in client.subscribe_to_events_store(
subscription: EventsStoreSubscription,
cancellation_token: AsyncCancellationToken,
): # yields EventStoreReceived
...EventsStoreSubscription adds:
| Field | Type | Description |
|---|---|---|
events_store_type | EventStoreStartPosition | Replay start enum |
events_store_sequence_value | int | Sequence or timestamp value |
Start position values:
StartFromNew, StartFromFirst, StartFromLast, StartAtSequence, StartAtTime, StartAtTimeDelta.
Quick Usage
msg = EventStoreMessage(channel="audit", body=b"record")
result = await client.send_event_store(msg)See Also
Was this page helpful?