deegzlibs-event-bus 1.0.0

A small event bus with pluggable queue adapters and response stores (e.g. SQS, RabbitMQ, Redis, etc.)

DeegzLibs EventBus (Python)

A small event bus with pluggable queue adapters. Define event messages as Pydantic models, register handlers, and execute events in-process or via a queue (e.g. AWS SQS, RabbitMQ, Redis).

Installation

pip install deegzlibs-event-bus

Optional extras: [sqs], [redis], [rabbitmq]. See Installation.

Quick start

from event_bus import EventBus, EventBusRegistry, EventMessage, EventMessageHandler
from event_bus.adapters import InMemoryEventBusAdapter

registry = EventBusRegistry()
adapter = InMemoryEventBusAdapter(queue_name="events")
bus = EventBus(queue_adapter=adapter, event_registry=registry)

@registry.event()
def on_order_created(order_id: str, amount_cents: int):
    print(f"Order {order_id}: {amount_cents} cents")

# Fire-and-forget
await bus.execute(on_order_created(order_id="ord-1", amount_cents=1999), wait=False)

# Worker: poll and dispatch
await bus.work()

For full examples (messages, handlers, SQS/Redis, execute-and-wait), see the documentation.

Documentation

Topic	Description
Installation	Package and extras.
Quick start	Messages, handlers, register, execute.
Handler decorator	@registry.event() and message factory.
Message formats and parsers	Repr, JSON, Base64, custom parser.
Client and worker	Shared module, producer, consumer.
Queue adapters	In-memory, SQS, RabbitMQ, Redis.
Execute and wait	Response store, request/response.
API reference	Types and methods overview.

License

MIT