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.
Installation
pip install aio-pikaUsage example
import asyncio
from aio_pika import connect
@asyncio.coroutine
def main(loop):
connection = yield from connect("amqp://guest:guest@127.0.0.1/", loop=loop)
queue_name = "test_queue"
routing_key = "test_queue"
# Creating channel
channel = yield from connection.channel()
# Declaring exchange
exchange = yield from channel.declare_exchange('direct', auto_delete=True)
# Declaring queue
queue = yield from channel.declare_queue(queue_name, auto_delete=True)
# Binding queue
yield from queue.bind(exchange, routing_key)
yield from exchange.publish(
Message(
bytes('Hello', 'utf-8'),
content_type='text/plain',
headers={'foo': 'bar'}
),
routing_key
)
# Receiving message
incoming_message = yield from queue.get(timeout=5)
# Confirm message
incoming_message.ack()
yield from queue.unbind(exchange, routing_key)
yield from queue.delete()
yield from connection.close()
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))See another examples and the tutorial in documentation.
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.9.2.tar.gz
(13.3 kB
view details)
Built Distribution
aio_pika-0.9.2-py3-none-any.whl
(18.8 kB
view details)
File details
Details for the file aio-pika-0.9.2.tar.gz.
File metadata
- Download URL: aio-pika-0.9.2.tar.gz
- Upload date:
- Size: 13.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | a6e49984e1d3c786c0e74d8b1a029edd09687e93a061e399666debd0ff1e7e66 |
|
| MD5 | 44c3091a78649368a8d835f5cefba5d0 |
|
| BLAKE2b-256 | 47c19acf75ed15eefa6438e2c6666d6f48c9ecca2f6842efe16bb99e8bfc99ab |
File details
Details for the file aio_pika-0.9.2-py3-none-any.whl.
File metadata
- Download URL: aio_pika-0.9.2-py3-none-any.whl
- Upload date:
- Size: 18.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | f61add4d56e7d205e85716a2c72a5af1e05231ae57fcef908144ef234bae282f |
|
| MD5 | c978b2f478f21f9aed54a8aaa52ab9ed |
|
| BLAKE2b-256 | 2bfc507002621c06374ecc8d98f501272b2bb0aa510f3f5da6a0a5c43a1817a2 |
