Wrapper for the PIKA for asyncio and humans.
Project description
Wrapper for the PIKA for asyncio and humans. See examples and the tutorial in documentation.
If you are newcomer in the RabbitMQ let’s start the adopted official RabbitMQ tutorial
Installation
pip install aio-pikaUsage example
import asyncio
from aio_pika import connect, Message
async def main(loop):
connection = await connect("amqp://guest:guest@127.0.0.1/", loop=loop)
queue_name = "test_queue"
routing_key = "test_queue"
# Creating channel
channel = await connection.channel()
# Declaring exchange
exchange = await channel.declare_exchange('direct', auto_delete=True)
# Declaring queue
queue = await channel.declare_queue(queue_name, auto_delete=True)
# Binding queue
await queue.bind(exchange, routing_key)
await exchange.publish(
Message(
bytes('Hello', 'utf-8'),
content_type='text/plain',
headers={'foo': 'bar'}
),
routing_key
)
# Receiving message
incoming_message = await queue.get(timeout=5)
# Confirm message
incoming_message.ack()
await queue.unbind(exchange, routing_key)
await queue.delete()
await connection.close()
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))See another examples and the tutorial in documentation.
For contributors
You feel free for
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
aio-pika-0.12.0.tar.gz
(15.7 kB
view details)
File details
Details for the file aio-pika-0.12.0.tar.gz.
File metadata
- Download URL: aio-pika-0.12.0.tar.gz
- Upload date:
- Size: 15.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | cb4a4eafa15f0242a2fbba127e57b79ac0b566279e065ee7fdfdca91181c9c1f |
|
| MD5 | 26ce95f6c83118dbde4ca7cf9d6d4282 |
|
| BLAKE2b-256 | 6168d0135ee025c085831b326506311c7af0889a8d7077e3c195ae17fcf2ee73 |
