RabbitMQ broker for taskiq
Project description
AioPika broker for taskiq
This lirary provides you with aio-pika broker for taskiq.
Usage:
from taskiq_aio_pika import AioPikaBroker
broker = AioPikaBroker()
@broker.task
async def test() -> None:
print("nothing")
Configuration
AioPikaBroker parameters:
url
- url to rabbitmq. If None, "amqp://guest:guest@localhost:5672" is used.result_backend
- custom result backend.task_id_generator
- custom task_id genertaor.exchange_name
- name of exchange that used to send messages.exchange_type
- type of the exchange. Used only ifdeclare_exchange
is True.queue_name
- queue that used to get incoming messages.routing_key
- that used to bind that queue to the exchange.declare_exchange
- whether you want to declare new exchange if it doesn't exist.qos
- number of messages that worker can prefetch.
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
taskiq-aio-pika-0.0.5.tar.gz
(5.5 kB
view hashes)
Built Distribution
Close
Hashes for taskiq_aio_pika-0.0.5-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 513337cca3b7bb56515c3bd9b7d1b4ee853e6134ca8515122605b1a78f0a2b95 |
|
MD5 | 7b48a5f67aa60af24716bc3848b35f06 |
|
BLAKE2b-256 | 726cbb81d0a93f67a39a429abc0f9e5c0832e0c1e142e39d2be709b6e7dc0374 |