aio-pika
Wrapper for the aiormq 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
Features
Completely asynchronous API.
Object oriented API.
Transparent auto-reconnects with complete state recovery with connect_robust (e.g. declared queues or exchanges, consuming state and bindings).
Python 3.5+ compatible (include 3.7).
For python 3.4 users available aio-pika<4
Transparent publisher confirms support
Transactions support
Installation
pip install aio-pikaUsage example
Simple consumer:
import asyncio
import aio_pika
async def main(loop):
connection = await aio_pika.connect_robust(
"amqp://guest:guest@127.0.0.1/", loop=loop
)
async with connection:
queue_name = "test_queue"
# Creating channel
channel = await connection.channel() # type: aio_pika.Channel
# Declaring queue
queue = await channel.declare_queue(
queue_name,
auto_delete=True
) # type: aio_pika.Queue
async with queue.iterator() as queue_iter:
# Cancel consuming after __aexit__
async for message in queue_iter:
async with message.process():
print(message.body)
if queue.name in message.body.decode():
break
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()Simple publisher:
import asyncio
import aio_pika
async def main(loop):
connection = await aio_pika.connect_robust(
"amqp://guest:guest@127.0.0.1/", loop=loop
)
routing_key = "test_queue"
channel = await connection.channel() # type: aio_pika.Channel
await channel.default_exchange.publish(
aio_pika.Message(
body='Hello {}'.format(routing_key).encode()
),
routing_key=routing_key
)
await connection.close()
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()Get single message example:
import asyncio
from aio_pika import connect_robust, Message
async def main(loop):
connection = await connect_robust(
"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
await 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.
Versioning
This software follows Semantic Versioning
For contributors
Setting up development environment
Clone the project:
git clone https://github.com/mosquito/aio-pika.git
cd aio-pikaCreate a new virtualenv for aio_pika:
virtualenv -p python3.5 envInstall all requirements for aio_pika:
env/bin/pip install -e '.[develop]'Running Tests
NOTE: In order to run the tests locally you need to run a RabbitMQ instance with default user/password (guest/guest) and port (5672).
ProTip: Use Docker for this:
docker run -d -p 5672:5672 -p 15672:15672 rabbitmq:3-managementTo test just run:
make testCreating Pull Requests
You feel free to create pull request, but you should describe your cases and add some examples.
The changes should follow simple rules:
When your changes breaks public API you must increase the major version.
When your changes is safe for public API (e.g. added an argument with default value)
You have to add test cases (see tests/ folder)
You must add docstrings
You feel free to add yourself to “thank’s to” section
1 maintainer
Metadata
1 maintainer
Release files for aio-pika 6.0.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| aio-pika-6.0.1.tar.gz | 29.6 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| aio_pika-6.0.1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 69.1 kB
Release files / aio-pika-6.0.1.tar.gz
| Download URL | aio-pika-6.0.1.tar.gz |
|---|---|
| Size | 29.6 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
6e1abbb0b3ca369070c0e09aa17197fd5cf18f3c12dd27fb20bc7656c9b30e6e
|
|
BLAKE2b-256 checksum How to use checksums |
d338f3fbc793157cde6201faa59a419705d43a0ba8bf7b4c5ff34a1fc02ac093
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/3.7.3
|
Release files / aio_pika-6.0.1-py3-none-any.whl
| Download URL | aio_pika-6.0.1-py3-none-any.whl |
|---|---|
| Size | 39.6 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
5ee4b2c967c3532964036c00afc61bf43d489447b75a0abf99aa6af986e06bca
|
|
BLAKE2b-256 checksum How to use checksums |
e4d9225e56d3e5e3cb4ae0389aded9e32c8a83ef0d18460ffb505a62881342fe
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.13.0 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/3.7.3
|
