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.max_connection_pool_size
- maximum number of connections in pool.max_channel_pool_size
- maximum number of channels for each connection.
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.3.tar.gz
(5.4 kB
view hashes)
Built Distribution
Close
Hashes for taskiq_aio_pika-0.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 13d436d827959430215390e73e0eb4e360917f56ad773dc851e5d0b561b24f47 |
|
MD5 | d266973a3926dccaf52b84969a113f0e |
|
BLAKE2b-256 | 26dc1d6a4d813a018da5277b13ee2fdb9a7adbe5a3f93fe25262cc617b251e13 |