aio-pika-msgpack-rpc
Project description
aio-pika-msgpack-rpc
Requires Python >= 3.7.
Installation
pip install aio-pika-msgpack-rpc
Example
import asyncio
import aio_pika
from aio_pika_msgpack_rpc import MSGPackRPC
async def main():
client = await aio_pika.connect_robust('amqp://guest:guest@localhost:5672/')
channel = await client.channel()
rpc = await MSGPackRPC.create(channel)
# rpc calls
result = await rpc.call('method_name', kwargs={'test': 'data'})
asyncio.get_event_loop().run_until_complete(main())
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for aio-pika-msgpack-rpc-1.0.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 76886e3b09850aafa30be531265cc0b91cc9d9b876d4bf6b0c5b10369559b909 |
|
MD5 | 0bb10cff8ccfac1acb813f7644948182 |
|
BLAKE2b-256 | 30614ce3b77694b0d772b1684d5581f7980d899c47170838e521df3fd6aa82cd |
Close
Hashes for aio_pika_msgpack_rpc-1.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c8354e68a54e42130af1edb107bb22dde095f96bba2bf4b5cbe434e5014a91f3 |
|
MD5 | 49127e0413c70c065ab806fd75032da7 |
|
BLAKE2b-256 | 41e8dad3d7769cf27d04469d29a3dc36a331f2434d5711b2a2a654c2f016f528 |