pika/pika
Pika
Pika is a Python client library for implementing communication between applications and message brokers using the AMQP 0-9-1 protocol. It serves as a toolkit for sending and receiving messages, specifically enabling the creation of producers and consumers that interact with RabbitMQ and other AMQP-compliant brokers.
The library provides both an asynchronous messaging framework that integrates with external event loops for non-blocking data exchange and a procedural synchronous wrapper for performing messaging tasks without an asynchronous architecture.
Its connection management toolkit includes automatic connection recovery, heartbeat monitoring, and fault-tolerant retry strategies. The system employs a state machine to track network lifecycles and supports multi-endpoint failover logic to maintain connectivity during broker server failures.
The library also includes thread-safe callback routing to move tasks from background network threads to the primary execution loop.
Features
- AMQP Protocol Clients - Implements the AMQP 0-9-1 protocol to enable communication between Python applications and message brokers.
- AMQP - Implements the binary AMQP 0-9-1 protocol for encoding and decoding messages transmitted to brokers.
- Message Broker Connectivity - Provides synchronous and asynchronous adapters to establish communication links with AMQP message brokers.
- RabbitMQ Integrations - Provides a toolkit for building producers and consumers that interact specifically with RabbitMQ brokers.
- Connection Lifecycle State Machines - Uses a formal state machine to track network lifecycle transitions, handling reconnections and heartbeat monitoring.
- Connection Lifecycle Managers - Handles network lifecycles including automated state transitions, heartbeats, and reconnection logic.
- Automatic Connection Recovery - Automatically detects network failures and restores active connections and channels using retry strategies.
- Non-Blocking Event Loops - Integrates with external event loops to perform non-blocking network operations and manage message flow.
- Asynchronous Messaging Frameworks - Implements non-blocking communication patterns using an external event loop to handle high message volumes.
- Synchronous Messaging Interfaces - Provides a procedural synchronous wrapper for performing messaging tasks without requiring an asynchronous architecture.
- Distributed Service Communications - Enables reliable data exchange between decoupled services across different network nodes.
- Asynchronous-to-Synchronous Wrappers - Wraps asynchronous logic in a high-level procedural interface to allow sequential messaging tasks.
- Persistent Connection Management - Manages persistent connections with automatic retries and heartbeat monitoring to prevent data loss.
- Multi-Host Failover - Maintains connectivity during server failures by rotating through a list of configured host addresses.
- Sequential Host Failover - Implements sequential host failover by iterating through a list of host nodes to maintain connectivity.
Star history
How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.
