This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

API Reference

Release:

5.5

Date:

Apr 22, 2025

Kombu Core

• Kombu - kombu
• Common Utilities - kombu.common
• Pattern matching registry - kombu.matcher
• Mixin Classes - kombu.mixins
• Simple Messaging API - kombu.simple
• Logical Clocks and Synchronization - kombu.clocks
• Carrot Compatibility - kombu.compat
• Pidbox - kombu.pidbox
• Exceptions - kombu.exceptions
• Logging - kombu.log
• Connection - kombu.connection
• Message Objects - kombu.message
• Message Compression - kombu.compression
• Connection/Producer Pools - kombu.pools
• Abstract Classes - kombu.abstract
• Resource Management - kombu.resource
• Message Serialization - kombu.serialization

Kombu Transports

• Built-in Transports - kombu.transport
• Transport Base Class - kombu.transport.base
• Virtual Transport Base Class - kombu.transport.virtual
• Virtual AMQ Exchange Implementation - kombu.transport.virtual.exchange
• Azure Storage Queues Transport - kombu.transport.azurestoragequeues
• Azure Service Bus Transport - kombu.transport.azureservicebus
• Pure-python AMQP Transport - kombu.transport.pyamqp
• librabbitmq AMQP transport - kombu.transport.librabbitmq
• Apache QPid Transport - kombu.transport.qpid
• In-memory Transport - kombu.transport.memory
• Redis Transport - kombu.transport.redis
• MongoDB Transport - kombu.transport.mongodb
• Consul Transport - kombu.transport.consul
• Etcd Transport - kombu.transport.etcd
• Zookeeper Transport - kombu.transport.zookeeper
• File-system Transport - kombu.transport.filesystem
• SQLAlchemy Transport Model - kombu.transport.sqlalchemy
• Amazon SQS Transport - kombu.transport.SQS
• SLMQ Transport - kombu.transport.SLMQ
• Pyro Transport - kombu.transport.pyro

Kombu Asynchronous

• Event Loop - kombu.asynchronous
• Event Loop Implementation - kombu.asynchronous.hub
• Semaphores - kombu.asynchronous.semaphore
• Timer - kombu.asynchronous.timer
• Event Loop Debugging Utils - kombu.asynchronous.debug
• Async HTTP Client - kombu.asynchronous.http
• Async HTTP Client Interface - kombu.asynchronous.http.base
• Urllib3 HTTP Client Pool - kombu.asynchronous.http.urllib3_client
• Async Amazon AWS Client - kombu.asynchronous.aws
• Amazon AWS Connection - kombu.asynchronous.aws.connection
• Async Amazon SQS Client - kombu.asynchronous.aws.sqs
• SQS Connection - kombu.asynchronous.aws.sqs.connection
• SQS Messages - kombu.asynchronous.aws.sqs.message
• SQS Queues - kombu.asynchronous.aws.sqs.queue

Kombu utils

• Generic RabbitMQ manager - kombu.utils.amq_manager
• Custom Collections - kombu.utils.collections
• Python Compatibility - kombu.utils.compat
• Debugging Utilities - kombu.utils.debug
• Div Utilities - kombu.utils.div
• String Encoding Utilities - kombu.utils.encoding
• Async I/O Selectors - kombu.utils.eventio
• Functional-style Utilities - kombu.utils.functional
• Module Importing Utilities - kombu.utils.imports
• JSON Utilities - kombu.utils.json
• Rate limiting - kombu.utils.limits
• Object/Property Utilities - kombu.utils.objects
• Consumer Scheduling - kombu.utils.scheduling
• Text utilitites - kombu.utils.text
• Time Utilities - kombu.utils.time
• URL Utilities - kombu.utils.url
• UUID Utilities - kombu.utils.uuid