App AMQP API: app.amqp.

Connection¶

Broker connection class used. Default is kombu.Connection.

Consumer¶

Base Consumer class used. Default is kombu.Consumer.

Producer¶

Base Producer class used. Default is kombu.Producer.

queues¶

All currently defined task queues (a Queues instance).

argsrepr_maxsize¶

Max size of positional argument representation used for logging purposes. Default is 1024.

kwargsrepr_maxsize¶

Max size of keyword argument representation used for logging purposes. Default is 1024.

Queues(queues, create_missing=None, autoexchange=None, max_priority=None)[исходный код]¶

Router(queues=None, create_missing=None)[исходный код]¶

Return the current task router.

flush_routes()[исходный код]¶

create_task_message¶

send_task_message¶

default_queue¶

default_exchange¶

producer_pool¶

router¶

routes¶

Queue name⇒ declaration mapping.

Параметры:

• queues (Iterable) – Initial list/tuple or dict of queues.

• create_missing (bool) – By default any unknown queues will be added automatically, but if this flag is disabled the occurrence of unknown queues in wanted will raise KeyError.

• max_priority (int) – Default x-max-priority for queues with none set.

add(queue, **kwargs)[исходный код]¶

Add new queue.

The first argument can either be a kombu.Queue instance, or the name of a queue. If the former the rest of the keyword arguments are ignored, and options are simply taken from the queue instance.

Параметры:

• queue (kombu.Queue, str) – Queue to add.

• exchange (kombu.Exchange, str) – if queue is str, specifies exchange name.

• routing_key (str) – if queue is str, specifies binding key.

• exchange_type (str) – if queue is str, specifies type of exchange.

• **options (Any) – Additional declaration options used when queue is a str.

add_compat(name, **options)[исходный код]¶

property consume_from¶

deselect(exclude)[исходный код]¶

Deselect queues so that they won’t be consumed from.

Параметры:

exclude (Sequence[str], str) – Names of queues to avoid consuming from.

format(indent=0, indent_first=True)[исходный код]¶

Format routing table into string for log dumps.

new_missing(name)[исходный код]¶

select(include)[исходный код]¶

Select a subset of currently defined queues to consume from.

Параметры:

include (Sequence[str], str) – Names of queues to consume from.

select_add(queue, **kwargs)[исходный код]¶

Add new task queue that’ll be consumed from.

The queue will be active even when a subset has been selected using the celery worker -Q option.