wdg-kombu-sdk 0.1.0

Reusable Kombu-based publisher/consumer SDK for Django projects.

wdg-kombu-sdk

A reusable Kombu-based publisher/consumer SDK for Django projects. Easily connect to any message broker (RabbitMQ, Redis, etc.) using Django settings and environment variables.

Features

• Generic broker connection using Kombu
• Publisher and consumer classes for events
• Django settings integration (set broker URL in .env or settings.py)
• Ready for packaging and PyPI publishing

Installation

pip install wdg-kombu-sdk

Or clone and install locally:

pip install -r requirements.txt
python setup.py install

Configuration

Add your broker URL to your Django .env or settings.py:

BROKER_URL=amqp://guest:guest@localhost:5672//

or in settings.py:

import os
BROKER_URL = os.environ.get('BROKER_URL', 'amqp://guest:guest@localhost:5672//')

Usage

Publisher Example

from wdg_kombu_sdk.publisher import EventPublisher

publisher = EventPublisher()  # Uses settings.BROKER_URL by default
publisher.publish_event('user.created', {"id": 1, "name": "Alice"})

Consumer Example

from wdg_kombu_sdk.consumer import EventConsumer

def my_callback(body, message):
    print(body)
    message.ack()

consumer = EventConsumer('order_saga_compensator', callback=my_callback)  # Uses settings.BROKER_URL by default
consumer.start()

Advanced Usage

You can override the broker URL or exchange/queue settings if needed:

publisher = EventPublisher(broker_url='redis://localhost:6379/0', exchange_name='my_events')
consumer = EventConsumer('my_queue', broker_url='redis://localhost:6379/0', exchange_name='my_events')

Publishing to PyPI

1. Update setup.py with the correct package information.
2. Build the distribution:

python setup.py sdist bdist_wheel

3. Upload to PyPI using twine:

twine upload dist/*

---

License

MIT