This document describes the current stable version of Celery (5.4). For development docs, go here.

Creating events, and event exchange definition., _fields=None, __dict__=<class 'dict'>, __now__=<built-in function time>, **fields)[source]

Create an event.


An event is simply a dictionary: the only required field is type. A timestamp field will be set to the current time if not provided. = <unbound Exchange celeryev(topic)>

Exchange used to send events on. Note: Use get_exchange() instead, as the type of exchange will vary depending on the broker connection., name='celeryev')[source]

Get exchange used for sending events.

  • conn (kombu.Connection) – Connection used for sending/receiving events.

  • name (str) – Name of the exchange. Default is celeryev.


The event type changes if Redis is used as the transport (from topic -> fanout).[source]

Get the group part of an event type name.


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