kombu-producer 0.1.1

Python library that implements a simple Kombu producer

Kombu Producer

Python library that implements a simple Kombu producer

Installation

pip install kombu-producer

Publishing event with payload

from kombu_producer import KombuProducer
from json import dumps

KombuProducer(
            exchange_name="<EXCHANGE_NAMED>",
            exchange_type="<EXCHANGE_TYPE>",
            routing_key="<ROUTING_KEY>",
            broker_url="<BROKER_URL>"
        ).publish_payload(
            payload=dumps(
                {
                    "event": "<EVENT_NAME>",
                    "data": {
                        "<KEY1>": "<VAL1>",
                        "<KEY2>": "<VAL2>",
                    },
                }
            )
        )