This document describes the current stable version of Celery (5.4). For development docs, go here.
Sending/Receiving Messages (Kombu integration).
AMQP¶
- class celery.app.amqp.AMQP(app)[source]¶
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
.
- 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.
- create_task_message¶
- send_task_message¶
- default_queue¶
- default_exchange¶
- producer_pool¶
- router¶
- routes¶
Queues¶
- class celery.app.amqp.Queues(queues=None, default_exchange=None, create_missing=True, autoexchange=None, max_priority=None, default_routing_key=None)[source]¶
Queue name⇒ declaration mapping.
- Parameters:
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)[source]¶
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.- Parameters:
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.
- property consume_from¶
- select_add(queue, **kwargs)[source]¶
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.