celery.events.state

Диспетчер событий отправляет события.

classcelery.events.dispatcher.EventDispatcher(connection=None, hostname=None, enabled=True, channel=None, buffer_while_offline=True, app=None, serializer=None, groups=None, delivery_mode=1, buffer_group=None, buffer_limit=24, on_send_buffered=None)

Отправляет сообщения о событиях.

Параметры:

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

• hostname (str) – Имя хоста, используемое для идентификации; по умолчанию используется имя хоста, возвращаемое anon_nodename().

• groups (Sequence[str]) – Список групп, для которых нужно отправлять события. send() будет игнорировать запросы на отправку в группы, отсутствующие в этом списке. Если значение равно None, будут отправляться все события. Примеры групп: "task" и "worker".

• enabled (bool) – Установите значение False, чтобы не публиковать события; в этом случае send() ничего не будет делать.

• channel (kombu.Channel) – Можно использовать вместо connection, чтобы указать конкретный канал для отправки событий.

• buffer_while_offline (bool) – Если параметр включён, события будут помещаться в буфер, пока соединение недоступно. После восстановления соединения необходимо вызвать flush().

Примечание

После использования необходимо вызвать close().

DISABLED_TRANSPORTS={'sql'}

app=None

close()

Закрывает диспетчер событий.

disable()

enable()

extend_buffer(other)

Копирует буфер исходящих сообщений другого экземпляра.

flush(errors=True, groups=True)

Очищает буфер исходящих сообщений.

on_disabled=None

on_enabled=None

publish(type, fields, producer, blind=False, Event=<function Event>, **kwargs)

Публикует событие с помощью пользовательского Producer.

Параметры:

• type (str) – Имя типа события, группа отделяется дефисом (-). fields: словарь полей события; значения должны поддерживать сериализацию в JSON.

• producer (kombu.Producer) – Экземпляр производителя, который нужно использовать: будет вызван только метод publish.

• retry (bool) – Повторять попытку при сбое соединения.

• retry_policy (Mapping) – Словарь пользовательских параметров политики повторных попыток. См. ensure().

• blind (bool) – Не задавать значение логических часов (а также не передавать внутренние логические часы).

• Event (Callable) – Тип события, используемый для создания события. По умолчанию Event().

• utcoffset (Callable) – Функция, возвращающая текущее смещение UTC в часах.

propertypublisher

send(type, blind=False, utcoffset=<function utcoffset>, retry=False, retry_policy=None, Event=<function Event>, **fields)

Отправляет событие.

Параметры:

• type (str) – Имя типа события, группа отделяется дефисом (-).

• retry (bool) – Повторять попытку при сбое соединения.

• retry_policy (Mapping) – Словарь пользовательских параметров политики повторных попыток. См. ensure().

• blind (bool) – Не задавать значение логических часов (а также не передавать внутренние логические часы).

• Event (Callable) – Тип события, используемый для создания события; по умолчанию Event().

• utcoffset (Callable) – Функция, возвращающая текущее смещение UTC в часах.

• **fields (Any) – Поля события; значения должны поддерживать сериализацию в JSON.