zimran-events
The zimran-py-events module provides AMQP interface
Installation
pip install zimran-events
Usage example
Producer
from zimran.events import AsyncProducer
producer = AsyncProducer(broker_url='')
await producer.connect()
# message publishing
await producer.publish('some.event.routing', {'msg': 'hello, world'})
Consumer
# < 0.4.0
from zimran.events import Consumer
from zimran.events.dto import Exchange
consumer = Consumer(service_name='my-service', broker_url='')
consumer.add_event_handler(
name='routing-key',
handler=handler_func,
exchange=Exchange(
name='exchange-name',
type='exchange-type',
durable=True,
)
)
# or
from zimran.events import Consumer
consumer = Consumer(service_name='my-service', broker_url='')
@consumer.event_handler('routing-key')
def handler_func(**kwargs):
...
# >= 0.4.0 version
from zimran.events.routing import Router
from zimran.events.consumer AsyncConsumer
router = Router()
@router.event_handler('routing-key')
async def handler(message: aio_pika.IncomingMessage):
pass
router.add_event_handler('routing-key', some_handler)
async def main():
consumer = AsyncConsumer(..., router=router)
await consumer.run()
Code
The code and issue tracker are hosted on GitHub: https://github.com/zimran-tech/zimran-py-events.git
Features
- AMQP interfaces
For contributors
Setting up development environment
Clone the project:
git clone https://github.com/zimran-tech/zimran-py-events.git
cd zimran-py-events
Create a new virtualenv:
python3 -m venv venv
source venv/bin/activate
1 maintainer
Release files for zimran-events 0.6.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| zimran_events-0.6.0.tar.gz | 15.2 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| zimran_events-0.6.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 27.0 kB
Release files / zimran_events-0.6.0.tar.gz
| Download URL | zimran_events-0.6.0.tar.gz |
|---|---|
| Size | 15.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
3d741e0ac5206d1533f21d0341d4681eb4bd40782748f4b0a9a3209e0fd47ec2
|
|
BLAKE2b-256 checksum How to use checksums |
68ce772e34be195db2da1d44d2d6bd7dc8be88bf1d87a923fb32d9e29214a80e
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.12.6
|
Release files / zimran_events-0.6.0-py3-none-any.whl
| Download URL | zimran_events-0.6.0-py3-none-any.whl |
|---|---|
| Size | 11.8 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
07b7d88d5cee36ba0474ecc2afa922ec8c4862cfa33b6f9ba2081dc16bdf8037
|
|
BLAKE2b-256 checksum How to use checksums |
4541b4e2eddf66b2d2550616441a6f566212402c2b55c3731974e7b4ea951790
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.12.6
|
