django-pika-pubsub

Django-pika-pubsub is a simple Django app to publish and consume rmq-messages via Pika.

Using default rmq exchange.

Quick start

Add “django_pika_pubsub” to your INSTALLED_APPS setting like this:
```
INSTALLED_APPS = [
    ...
    'django_pika_pubsub',
]
```

Add the following to your settings.py module:

PUBSUB = {
        'RABBITMQ_USERNAME': os.getenv('RABBITMQ_USERNAME'),
        'RABBITMQ_PASSWORD': os.getenv('RABBITMQ_PASSWORD'),
        'RABBITMQ_HOST': os.getenv('RABBITMQ_HOST'),
        'RABBITMQ_PORT': int(os.getenv('RABBITMQ_PORT')),
}

Do something similar for producing messages:

from django_pika_pubsub import Producer
...
producer = Producer.get_producer()
producer.produce(
        body={'id': order.id},
        routing_key='order.sent.order_id.1.0.0'
)

Do something similar for consuming messages:

consumer = MyConsumer.get_consumer()
consumer.consume(
        routing_key='test',
        callback=callback,
)


def callback(channel, method, properties, body):
        payload = json.loads(body)
        order_id = payload.get('id')
        if order_id:
                print(f'{order_id=}')

Release files for django-pika-pubsub 0.6

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for django-pika-pubsub 0.6
File	Size	Uploaded
django-pika-pubsub-0.6.tar.gz	4.6 kB	Feb 8, 2020	Details

Release files / django-pika-pubsub-0.6.tar.gz

Download URL	django-pika-pubsub-0.6.tar.gz
Size	4.6 kB
Tags	Source
SHA-256 checksum How to use checksums	`03f0415ac983f1f219cdb15831770334429e0bc9dde45b32704c7ab5ada646c9`
BLAKE2b-256 checksum How to use checksums	`58963e3620078602b666f0fbb681b058f144d0d8aa6a94d9ebaa22f280e90be1`
Upload date	Feb 8, 2020
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/3.1.1 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.2.0 requests-toolbelt/0.9.1 tqdm/4.42.1 CPython/3.8.0`