---
id: taskiq-aio-pika
version: "0.6.0"
license: MIT
license_treatment: permissive
maintenance: active
---

# taskiq-aio-pika — RabbitMQ broker for taskiq

License: permissive · Maintenance: active · Downloads: 356.1K/mo

## What it is and what it does

taskiq-aio-pika is a RabbitMQ broker for the taskiq async task queue framework. It connects taskiq's task distribution model to RabbitMQ as the underlying message broker, allowing you to define async tasks with decorators and execute them across distributed workers. The package handles the full lifecycle of task serialization, routing, and delivery through RabbitMQ.

It supports delayed task execution via dead-letter queues or the RabbitMQ delayed-message-exchange plugin, message priorities for controlling delivery order, and multi-queue setups with custom routing keys. Tasks can be defined with default delays and priorities, then overridden per-invocation using kicker labels. Configuration is declarative through Queue and Exchange objects that merge with broker defaults.

Use it for:

- Distribute long-running async operations across multiple worker processes using RabbitMQ as the message backbone.
- Schedule tasks to execute after a delay, using either dead-letter expiration or the delayed-message-exchange plugin.
- Prioritize certain tasks over others by assigning priority labels, ensuring high-urgency work is processed first.
- Route different task types to separate queues with custom routing keys for workload isolation and scaling.
- Build a microservice architecture where multiple services publish and consume tasks through a shared RabbitMQ cluster.

## Worth the install?

AI-flagged interpretation of the facts above — verify before relying.

Provides a RabbitMQ broker implementation for taskiq, enabling asynchronous task distribution with support for delayed messages, priorities, and multi-queue routing.

Yes. The package is actively maintained, has low install friction, carries no known vulnerabilities, and is MIT-licensed. It fills a clear role as the RabbitMQ integration for taskiq. Install it if you need RabbitMQ as your task broker; skip it if you're using a different broker or don't need distributed async task execution.

## Install

pip install taskiq-aio-pika
uv add taskiq-aio-pika
poetry add taskiq-aio-pika

## Installing taskiq-aio-pika

Before you install: Low install friction with three runtime dependencies (taskiq, aio-pika, aiostream). Actively maintained with recent releases; supports Python 3.10 through 3.13.

License in practice: MIT license permits commercial and private use with minimal restrictions; suitable for most projects.

Quickstart:

pip install taskiq-aio-pika

from taskiq_aio_pika import AioPikaBroker

broker = AioPikaBroker()

@broker.task
async def test() -> None:
    print("nothing")

Requires a running RabbitMQ server; Python 3.10 or later.

Verify before relying:

- Whether the delayed-message-exchange plugin is optional or required for delay functionality
- Performance characteristics under high message volume or with many concurrent tasks

## Package facts

- License: MIT (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: active
- Downloads: 356.1K/month (top 15,000 on PyPI)
- Known vulnerabilities: none known

## Tags

rabbitmq task queue broker, async task distribution, taskiq rabbitmq integration, delayed message queue, distributed task scheduling, aio-pika broker, async job queue, rabbitmq, async-tasks, task-queue

[View on SkillFed](https://skillfed.io/packages/taskiq-aio-pika) · [View on PyPI](https://pypi.org/project/taskiq-aio-pika/)