taskiq-aio-pika

library0.6.0pypypi✓ verified 85d ago

taskiq-aio-pika is a broker implementation for the Taskiq asynchronous task queue, enabling it to use RabbitMQ as a message broker. It leverages aio-pika for asynchronous AMQP communication, providing robust and scalable message passing. The current version is 0.6.0 and it typically follows the release cadence of the main Taskiq library.

workflow communication

pip install taskiq-aio-pika

package ↗

INSTALL

IMPORT

SIG · TASKIQ-AIO-PIKA

taskiq-aio-pika

workflowpythonv0.6.0

Install

6.5s avg

Import

1248ms

Disk

42MB

Pass rate

10/ 10

Env Coverage10 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v0.6.0 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

py 3.10–3.910 runs

installs and imports cleanly · install 0.0s · import 1.313s · 41.6MB

glibc

py 3.10–3.910 runs

installs and imports cleanly · install 6.5s · import 1.182s · 43MB

42MB installed

● package 42MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

AioPikaBroker

✓ from taskiq_aio_pika import AioPikaBroker

This quickstart demonstrates how to configure `taskiq-aio-pika` by defining a `TaskiqSettings` class with an `AioPikaBroker` instance pointing to your RabbitMQ server. A simple task `process_data` is then defined using the broker's decorator. To run the worker, execute `taskiq worker your_module_name:settings_instance` in your terminal.

import os from taskiq import TaskiqSettings from taskiq_aio_pika import AioPikaBroker # Configure RabbitMQ connection using environment variable or a default RABBITMQ_URL = os.environ.get( "RABBITMQ_URL", "amqp://guest:guest@localhost:5672/" ) class AppSettings(TaskiqSettings): """Taskiq settings with AioPikaBroker for RabbitMQ.""" broker: AioPikaBroker = AioPikaBroker( url=RABBITMQ_URL, ) # Instantiate the settings settings = AppSettings() # Define a task using the broker's decorator @settings.broker.task async def process_data(data: str) -> str: """A simple task to process some data.""" print(f"Processing: {data}") return f"Processed: {data.upper()}" # To enqueue this task: # import asyncio # asyncio.run(process_data.kiq(data="hello world")) # To run the worker (assuming this code is in `app_settings.py`): # taskiq worker app_settings:settings

Debug

Known issues

gotchaRabbitMQ server must be running and accessible at the specified URL. If RabbitMQ is not running or the connection URL (e.g., host, port, credentials) is incorrect, the broker will fail to connect.

fix

Ensure RabbitMQ is running. Verify the `url` parameter passed to `AioPikaBroker` (e.g., `amqp://guest:guest@localhost:5672/`). Check firewall rules or Docker network configurations.

affects: All versions

breakingMajor version updates of `taskiq` (e.g., `0.x` to `0.y` with significant changes) may introduce breaking changes to its internal APIs or settings structure that `taskiq-aio-pika` relies on. This can lead to unexpected errors or require broker updates.

fix

Always check the release notes for both `taskiq` and `taskiq-aio-pika` when upgrading. Upgrade both libraries concurrently to compatible versions, as specified in `taskiq-aio-pika`'s `pyproject.toml` or `requirements.txt`.

affects: Potentially between `taskiq` major versions.

gotchaPydantic version conflicts can occur if other dependencies in your project require a different major version of Pydantic than what `taskiq` and `taskiq-aio-pika` expect. `taskiq-aio-pika` v0.6.0 is built for Pydantic v2.

fix

Use a virtual environment to manage dependencies. Ensure all packages requiring Pydantic are compatible with Pydantic v2. If a legacy dependency requires Pydantic v1, consider isolating environments or finding alternatives.

affects: All versions, depending on environment.

Errors

Common errors & fixes

aio_pika.exceptions.AMQPConnectionError: [Errno 111] Connection refused

The RabbitMQ server is not running or is not accessible from the machine where the Taskiq worker is trying to connect.

fix

Start your RabbitMQ server. Verify the RabbitMQ host and port in your `AioPikaBroker` URL (e.g., `localhost:5672`). Check network connectivity and firewall settings.

ImportError: cannot import name 'AioPikaBroker' from 'taskiq_aio_pika'

The `taskiq-aio-pika` package is not installed, or there is a typo in the import statement.

fix

Ensure the package is installed: `pip install taskiq-aio-pika`. Double-check the spelling of `AioPikaBroker` and `taskiq_aio_pika`.

taskiq.exceptions.TaskIQException: Broker is not connected.

The `AioPikaBroker` failed to establish a connection to RabbitMQ after initialization, or the connection was lost.

fix

Examine the application logs for earlier `aio-pika` connection errors (e.g., `Connection refused`, `Authentication failed`). Verify RabbitMQ server status, credentials, and network reachability. This error often surfaces after underlying connection issues.

Upgrade

Version history

0.6.0latest on PyPI · released Feb 28, 2026

Audit

Dependencies

taskiqrequiredCore Taskiq library, required for broker functionality.

aio-pikarequiredAsynchronous RabbitMQ client, used internally by the broker.

Agent activity

27 hits · last 30 days

node

OpenAI (training)

Resources

packagehttps://pypi.org/project/taskiq-aio-pika/ ↗