eventiq-asb
Azure Service Bus broker implementation for eventiq
Installation
pip install eventiq-asb
With optional dependencies:
pip install 'eventiq-asb[aiohttp]'
Usage
from eventiq import CloudEvent, Service
from eventiq_asb import AzureServiceBusBroker, DeadLetterQueueMiddleware
service = Service(
name="example-service",
broker=AzureServiceBusBroker(
topic_name="example-topic", url="sb://example.servicebus.windows.net/"
),
)
service.add_middleware(DeadLetterQueueMiddleware)
@service.subscribe(topic="example-topic")
async def example_consumer(message: CloudEvent):
print(message.data)
Metadata
Release files for eventiq-asb 0.1.9
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| eventiq_asb-0.1.9.tar.gz | 11.6 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| eventiq_asb-0.1.9-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 23.4 kB
Release files / eventiq_asb-0.1.9.tar.gz
| Download URL | eventiq_asb-0.1.9.tar.gz |
|---|---|
| Size | 11.6 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
2c9522f6133752d2b847697fc23e640c1745a73fb3f97179b31d63145d44d93b
|
|
BLAKE2b-256 checksum How to use checksums |
871da32ce1e3e800bcfa110c93428f9badaaa71405dc4490e49d9ce57a843aeb
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.12.7
|
Release files / eventiq_asb-0.1.9-py3-none-any.whl
| Download URL | eventiq_asb-0.1.9-py3-none-any.whl |
|---|---|
| Size | 11.8 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
c970faa4c87580381da80a5339900c59108b712e4236c07ff2c0a05f06aa6815
|
|
BLAKE2b-256 checksum How to use checksums |
1fedd5fa0f7eea1284ad807abf22d604f2aa961352c4346cfec6b0366d65bba9
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.12.7
|