taskiq-aio-pika
RabbitMQ broker for taskiq
Decision gist · record as of 2026-08-14
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.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires a running RabbitMQ server; Python 3.10 or later.
- Low install friction with three runtime dependencies (taskiq, aio-pika, aiostream).
- Actively maintained with recent releases; supports Python 3.10 through 3.13.
License · maintenance · safety
MIT (permissive) — MIT license permits commercial and private use with minimal restrictions; suitable for most projects.
last release 2026-02-28 (167 days)
0 known vulnerabilities (OSV.dev, 2026-08-14) · 356,102 downloads/mo, #7,284 on PyPI
Alternatives
Verify before relying
pip install taskiq-aio-pika
from taskiq_aio_pika import AioPikaBroker
broker = AioPikaBroker()
@broker.task
async def test() -> None:
print("nothing")- Whether the delayed-message-exchange plugin is optional or required for delay functionality
- Performance characteristics under high message volume or with many concurrent tasks
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 on this page. Verify before relying on it.
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
taskiq-aio-pika on PyPI
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.
Requires a running RabbitMQ server; Python 3.10 or later.
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")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 the current Python release <4,>=3.10 |
| Install friction | Low. Pure-Python wheel |
| Runtime dependencies | 3 packagestaskiqaio-pikaaiostream |
| Maintenance | Actively maintained 167 days since the last release |
| First released | |
| Downloads | 356,102 / month, #7,284 on PyPI 30-day window, as of 2026-08-14 |
| Known vulnerabilities | None known OSV.dev, checked 2026-08-14 |
| Classifiers | Development Status :: 3 - AlphaIntended Audience :: DevelopersOperating System :: OS IndependentProgramming Language :: PythonProgramming Language :: Python :: 3Programming Language :: Python :: 3 :: OnlyProgramming Language :: Python :: 3.10Programming Language :: Python :: 3.11Programming Language :: Python :: 3.12Programming Language :: Python :: 3.13Topic :: System :: NetworkingTyping :: Typed |
Evidence: taskiq_aio_pika-0.6.0-py3-none-any.whl
Tags
Let your AI agent find packages like this
Example. Real query, live index.
You found this page by searching. An agent finds it by wishing: SkillFed indexes 14,416 PyPI packages by what they can do, searchable in plain language.
wish › “rabbitmq task queue broker”
- taskiq-aio-pikaProvides a RabbitMQ broker implementation for taskiq, enabling…
- dramatiqDramatiq is a distributed task processing library that lets you…
- aiormqaiormq is a pure Python AMQP 0.9.1 client library for asynchronous…
Give your agent the search over MCP, or paste the wish link into any chat.
More Networking packages
h11 is a pure-Python HTTP/1.1 protocol implementation that handles parsing and serializing HTTP messages without any built-in I/O, letting you integrate it with any network layer you choose.
psutil retrieves real-time information about running processes and system resources (CPU, memory, disks, network, sensors) across multiple operating systems, enabling system monitoring, process profiling, and resource management.
pyOpenSSL wraps OpenSSL's SSL/TLS functionality for Python, providing high-level connection objects and certificate handling through a Python-friendly interface around OpenSSL's cryptographic operations.
uvloop is a drop-in replacement for Python's built-in asyncio event loop, implemented in Cython and using libuv, that accelerates async I/O operations.
execnet lets you spawn and communicate with Python interpreters across local processes, remote hosts, and different platforms, using a simple API for task distribution and inter-process messaging.
However, the aging maintenance status (275 days since last release) means you should verify it meets your concurrency and performance needs before committing to a…
PyZMQ provides Python bindings for ZeroMQ (ØMQ), a lightweight messaging library that enables fast, asynchronous communication between distributed processes and applications.
See also aio-pika · taskiq · taskiq-redis · taskiq-fastapi · opentelemetry-instrumentation-aio-pika · pika · redis-simple-mq · dramatiq · aiochannel · priority