This document describes the current stable version of Kombu (5.0). For development docs, go here.

Resource Management - kombu.resource

Generic resource pool implementation.

class kombu.resource.LifoQueue(maxsize=0)

Last in first out version of Queue.

class kombu.resource.Resource(limit=None, preload=None, close_after_fork=None)

Pool of resources.

exception LimitExceeded

Limit exceeded.

acquire(block=False, timeout=None)

Acquire resource.

Parameters

• block (bool) – If the limit is exceeded, then block until there is an available item.

• timeout (float) – Timeout to wait if block is true. Default is None (forever).

Raises

LimitExceeded – if block is false and the limit has been exceeded.

close_after_fork = False

close_resource(resource)

collect_resource(resource)

force_close_all()

Close and remove all resources in the pool (also those in use).

Used to close resources from parent processes after fork (e.g. sockets/connections).

property limit

prepare(resource)

release(resource)

release_resource(resource)

replace(resource)

Replace existing resource with a new instance.

This can be used in case of defective resources.

resize(limit, force=False, ignore_errors=False, reset=False)

setup()