你正在阅读 Celery 3.1 的文档。开发版本文档见： 此处.

celery.app.amqp

Sending and receiving messages using Kombu.

AMQP

class celery.app.amqp.AMQP(app)

Connection

Broker connection class used. Default is kombu.Connection.

Consumer

Base Consumer class used. Default is kombu.compat.Consumer.

queues

All currently defined task queues. (A Queues instance).

Queues(queues, create_missing=None, ha_policy=None, autoexchange=None)

Create new Queues instance, using queue defaults from the current configuration.

Router(queues=None, create_missing=None)

Return the current task router.

TaskConsumer None

Return consumer configured to consume from the queues we are configured for (app.amqp.queues.consume_from).

TaskProducer None

Return publisher used to send tasks.

You should use app.send_task instead.

flush_routes()

default_queue None

default_exchange None

publisher_pool None

router None

routes None

Queues

class celery.app.amqp.Queues(queues=None, default_exchange=None, create_missing=True, ha_policy=None, autoexchange=None)

Queue name⇒ declaration mapping.

参数:

• queues – Initial list/tuple or dict of queues.
• create_missing – By default any unknown queues will be added automatically, but if disabled the occurrence of unknown queues in wanted will raise KeyError.
• ha_policy – Default HA policy 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 instance or name of the queue.
• exchange – (if named) specifies exchange name.
• routing_key – (if named) specifies binding key.
• exchange_type – (if named) specifies type of exchange.
• **options – (if named) Additional declaration options.

add_compat(name, **options)

consume_from None

deselect(exclude)

Deselect queues so that they will not be consumed from.

参数:exclude – Names of queues to avoid consuming from. Can be iterable or string.

format(indent=0, indent_first=True)

Format routing table into string for log dumps.

new_missing(name)

select(include)

Sets consume_from by selecting a subset of the currently defined queues.

参数:include – Names of queues to consume from. Can be iterable or string.

select_add(queue, **kwargs)

Add new task queue that will be consumed from even when a subset has been selected using the -Q option.

select_remove(exclude)

Deselect queues so that they will not be consumed from.

参数:exclude – Names of queues to avoid consuming from. Can be iterable or string.

select_subset(include)

Sets consume_from by selecting a subset of the currently defined queues.

参数:include – Names of queues to consume from. Can be iterable or string.

TaskPublisher

class celery.app.amqp.TaskPublisher(channel=None, exchange=None, *args, **kwargs)

Deprecated version of TaskProducer.