celery.events.event

Создание событий и определение обменника событий.

celery.events.event.Event(type, _fields=None, __dict__=<class 'dict'>, __now__=<built-in function time>, **fields)

Создать событие.

Примечания

Событие — это просто словарь: единственное обязательное поле — type. Если поле timestamp не указано, ему будет присвоено текущее время.

celery.events.event.event_exchange=<unbound Exchange celeryev(topic)>

Обменник, используемый для отправки событий. Примечание: вместо него используйте get_exchange(), поскольку тип обменника зависит от подключения к брокеру.

celery.events.event.get_exchange(conn, name='celeryev')

Получить обменник, используемый для отправки событий.

Параметры:

• conn (kombu.Connection) – Подключение, используемое для отправки и получения событий.

• name (str) – Имя обменника. По умолчанию — celeryev.

Примечание

Тип события меняется, если в качестве транспорта используется Redis (с topic на fanout).

celery.events.event.group_from(type)

Получить часть с именем группы из названия типа события.

Пример

>>> group_from('task-sent')
'task'

>>> group_from('custom-my-event')
'custom'