opentelemetry-instrumentation-aio-pika

What it is and what it does

This package is an OpenTelemetry instrumentation plugin that automatically wraps Aio-pika (an async RabbitMQ client) to emit distributed tracing spans. When installed and initialized, it intercepts message queue operations—publishes, consumes, and acknowledgments—and reports them as trace events to your configured OpenTelemetry collector. It depends on the core OpenTelemetry API and instrumentation framework, plus wrapt for runtime patching.

It is designed for developers who already use OpenTelemetry for observability and want to add visibility into async message queue traffic. The instrumentation is passive once enabled; you configure it once in your application startup, and it begins collecting spans automatically. It is currently in beta status (version 0.65b0) and supports Python 3.10 through 3.14.

Use it for:

• Add distributed tracing to async RabbitMQ applications to track message flow across microservices.
• Debug message queue bottlenecks by correlating queue operations with other service traces in your observability platform.
• Monitor message publish and consume latency in production systems using OpenTelemetry exporters.
• Correlate async message processing with HTTP requests and database queries in end-to-end traces.
• Validate message queue behavior in integration tests by inspecting emitted trace spans.

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Adds distributed tracing instrumentation to Aio-pika, automatically capturing and reporting message queue operations to OpenTelemetry collectors.

Yes, if you already use OpenTelemetry and Aio-pika together. The package is actively maintained, has low install friction, carries no known vulnerabilities, and solves a real observability gap for async message queues. The beta status (0.65b0) is typical for OpenTelemetry instrumentation plugins and does not indicate instability. Install it only if you have an OpenTelemetry collector and exporter already configured.

Install

opentelemetry-instrumentation-aio-pika on PyPI

pip install opentelemetry-instrumentation-aio-pika

uv add opentelemetry-instrumentation-aio-pika

poetry add opentelemetry-instrumentation-aio-pika

Installing opentelemetry-instrumentation-aio-pika

Before you install

Low install friction with a pure-Python wheel. Actively maintained as of 2026-08-14 with recent release activity. Depends on four core OpenTelemetry packages (opentelemetry-api, opentelemetry-instrumentation, opentelemetry-semantic-conventions, wrapt), all standard instrumentation infrastructure.

License in practice

Apache-2.0 permissive license allows use in most commercial and open-source projects with minimal restrictions—include a copy of the license and note any material modifications.

Quickstart

pip install opentelemetry-instrumentation-aio-pika

from opentelemetry.instrumentation.aio_pika import AioPikaInstrumentor

AioPikaInstrumentor().instrument()

Requires Python >=3.10; an OpenTelemetry SDK and exporter must be configured separately to actually collect and export traces.

Verify before relying

• Whether this version (0.65b0) is production-ready or intended for pre-release testing only
• Specific Aio-pika versions supported by this instrumentation
• Whether additional OpenTelemetry exporter configuration is required beyond this package

Package facts

Evidence: opentelemetry_instrumentation_aio_pika-0.65b0-py3-none-any.whl

Tags

More Monitoring packages