This document describes the current stable version of Celery (4.3). For development docs, go here.
celery.events.event
¶
Creating events, and event exchange definition.
-
celery.events.event.
Event
(type, _fields=None, __dict__=<type 'dict'>, __now__=<built-in function time>, **fields)[source]¶ Create an event.
Notes
An event is simply a dictionary: the only required field is
type
. Atimestamp
field will be set to the current time if not provided.
-
celery.events.event.
event_exchange
= <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.
-
celery.events.event.
get_exchange
(conn, name=u'celeryev')[source]¶ Get exchange used for sending events.
Parameters: - conn (kombu.Connection) – Connection used for sending/receving events.
- name (str) – Name of the exchange. Default is
celeryev
.
Note
The event type changes if Redis is used as the transport (from topic -> fanout).