API AMQP приложения: app.amqp.

Connection

Используемый класс подключения к брокеру. По умолчанию — kombu.Connection.

Consumer

Используемый базовый класс Consumer. По умолчанию — kombu.Consumer.

Producer

Используемый базовый класс Producer. По умолчанию — kombu.Producer.

queues

Все текущие очереди задач (Queues).

argsrepr_maxsize

Максимальный размер представления позиционных аргументов, используемого для ведения журнала. По умолчанию — 1024.

kwargsrepr_maxsize

Максимальный размер представления именованных аргументов, используемого для ведения журнала. По умолчанию — 1024.

Queues(queues, create_missing=None, create_missing_queue_type=None, create_missing_queue_exchange_type=None, autoexchange=None, max_priority=None)

Router(queues=None, create_missing=None)

Возвращает текущий маршрутизатор задач.

flush_routes()

create_task_message

send_task_message

default_queue

default_exchange

producer_pool

router

routes

Сопоставление имен очередей с их объявлениями.

Параметры:

• queues (Iterable) – Исходный список/кортеж или словарь очередей.

• create_missing (bool) – По умолчанию любые неизвестные очереди добавляются автоматически, но если этот флаг отключён, появление неизвестных очередей в wanted вызовет KeyError.

• create_missing_queue_type (str) – Тип очереди, создаваемой для отсутствующих очередей. Допустимы значения ‘classic’ (по умолчанию) и ‘quorum’. Если задано значение ‘quorum’, брокер будет объявлять новые очереди с типом quorum.

• create_missing_queue_exchange_type (str) – Тип обменника, используемый при создании отсутствующих очередей. Если не задан, используется тип обменника по умолчанию. Если задан, при создании отсутствующих очередей будет использоваться это значение.

• max_priority (int) – Значение x-max-priority по умолчанию для очередей, в которых оно не задано.

add(queue, **kwargs)

Добавляет новую очередь.

Первый аргумент может быть экземпляром kombu.Queue или именем очереди. В первом случае остальные именованные аргументы игнорируются, а параметры берутся непосредственно из экземпляра очереди.

Параметры:

• queue (kombu.Queue, str) – Очередь для добавления.

• exchange (kombu.Exchange, str) – если queue имеет тип str, задаёт имя обменника.

• routing_key (str) – если queue имеет тип str, задаёт ключ привязки.

• exchange_type (str) – если queue имеет тип str, задаёт тип обменника.

• **options (Any) – Дополнительные параметры объявления, используемые, если queue имеет тип str.

add_compat(name, **options)

propertyconsume_from

deselect(exclude)

Исключает очереди из потребления.

Параметры:

exclude (Sequence[str], str) – Имена очередей, из которых не следует получать сообщения.

format(indent=0, indent_first=True)

Форматирует таблицу маршрутизации в строку для вывода в журнал.

new_missing(name)

select(include)

Выбирает подмножество текущих очередей для получения сообщений.

Параметры:

include (Sequence[str], str) – Имена очередей, из которых следует получать сообщения.

select_add(queue, **kwargs)

Добавляет новую очередь задач, из которой будут получаться сообщения.

Очередь будет активна, даже если с помощью параметра celery worker -Q выбрано подмножество очередей.