FileMgr

✏️ /usr/local/lib/python3.9/site-packages/celery/events/event.py

✕ Tutup

"""Creating events, and event exchange definition."""
import time
from copy import copy

from kombu import Exchange

__all__ = (
    'Event', 'event_exchange', 'get_exchange', 'group_from',
)

EVENT_EXCHANGE_NAME = 'celeryev'
#: Exchange used to send events on.
#: Note: Use :func:`get_exchange` instead, as the type of
#: exchange will vary depending on the broker connection.
event_exchange = Exchange(EVENT_EXCHANGE_NAME, type='topic')

def Event(type, _fields=None, __dict__=dict, __now__=time.time, **fields):
    """Create an event.

Notes:
        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.
    """
    event = __dict__(_fields, **fields) if _fields else fields
    if 'timestamp' not in event:
        event.update(timestamp=__now__(), type=type)
    else:
        event['type'] = type
    return event

def group_from(type):
    """Get the group part of an event type name.

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

>>> group_from('custom-my-event')
        'custom'
    """
    return type.split('-', 1)[0]

def get_exchange(conn, name=EVENT_EXCHANGE_NAME):
    """Get exchange used for sending events.

Arguments:
        conn (kombu.Connection): Connection used for sending/receiving 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).
    """
    ex = copy(event_exchange)
    if conn.transport.driver_type in {'redis', 'gcpubsub'}:
        # quick hack for Issue #436
        ex.type = 'fanout'
    if name != ex.name:
        ex.name = name
    return ex

Batal

⬅ celery 9 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📁 __pycache__	dir	—	08/05/25 20:25	0755	📂
🐍 __init__.py	py	477 B	08/05/25 20:25	0644	✏️ ⬇
🐍 cursesmon.py	py	17.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 dispatcher.py	py	8.8 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 dumper.py	py	3 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 event.py	py	1.7 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 receiver.py	py	4.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 snapshot.py	py	3.2 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 state.py	py	25 KB	08/05/25 20:25	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission