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.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | e7015bebe580eb58f6c91150e4107d9381ae05e6b530c68bdb086164c87f1ce9 |
|
MD5 | 8779f3359f0961d0b30a2f911281037e |
|
BLAKE2b-256 | 8c8d5ecdcab15b396b50ba663dcb244848c0024a4afd191be67452fa68581ec5 |
Close
Hashes for aio_pika_msgpack_rpc-1.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dde650d45395058e2c7b0452c03bb5c267425bc0ea5c91a2888cbd4eeec7f2d3 |
|
MD5 | faea1cc5272ed51726aa0eee4ab97ecd |
|
BLAKE2b-256 | 0bd7f78f0624ff8d4da12d7aa383aa405ad3d001d17cae31d4dae847ad7c3829 |