celery.events.snapshot

• celery.events.snapshot

celery.events.snapshot

Consuming the events as a stream is not always suitable so this module implements a system to take snapshots of the state of a cluster at regular intervals. There is a full implementation of this writing the snapshots to a database in djcelery.snapshots in the django-celery distribution.

class celery.events.snapshot.Polaroid(state, freq=1.0, maxrate=None, cleanup_freq=3600.0, timer=None, app=None)[源代码]

• cancel()[源代码]

• capture()[源代码]

• cleanup()[源代码]

• cleanup_signal = <Signal: Signal>

• clear_after = False

• install()[源代码]

• on_cleanup()[源代码]

• on_shutter(state)[源代码]

• shutter()[源代码]

• shutter_signal = <Signal: Signal>

• timer = None

celery.events.snapshot.evcam(camera, freq=1.0, maxrate=None, loglevel=0, logfile=None, pidfile=None, timer=None, app=None)[源代码]