celery.events.receiver

Реализация приёмника событий.

classcelery.events.receiver.EventReceiver(channel, handlers=None, routing_key='#', node_id=None, app=None, queue_prefix=None, accept=None, queue_ttl=None, queue_expires=None, queue_exclusive=None, queue_durable=None)

Перехват событий.

Параметры:

• connection (kombu.Connection) – Подключение к брокеру.

• handlers (Mapping[Callable]) – Обработчики событий. Это отображение имён типов событий на соответствующие обработчики. Специальный обработчик “*” перехватывает все события, для которых не задан обработчик.

app=None

capture(limit=None, timeout=None, wakeup=True)

Запустить потребителя для перехвата событий.

Этот метод должен выполняться в главном процессе и никогда не завершится, если только EventDispatcher.should_stop не установлено в True или выполнение не будет принудительно прервано с помощью KeyboardInterrupt или SystemExit.

propertyconnection

event_from_message(body, localize=True, now=<built-in function time>, tzfields=operator.itemgetter('utcoffset', 'timestamp'), adjust_timestamp=<function adjust_timestamp>, CLIENT_CLOCK_SKEW=-1)

get_consumers(Consumer, channel)

itercapture(limit=None, timeout=None, wakeup=True)

on_consume_ready(connection, channel, consumers, wakeup=True, **kwargs)

process(type, event)

Обработать событие, передав его настроенному обработчику.

wakeup_workers(channel=None)