celery.events.snapshot¶

Periodically store events in a database.

Consuming the events as a stream isn’t always suitable so this module implements a system to take snapshots of the state of a cluster at regular intervals. There’s 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)[исходный код]¶

Record event snapshots.

cancel()[исходный код]¶

capture()[исходный код]¶

cleanup()[исходный код]¶

cleanup_signal = <Signal: cleanup_signal providing_args=set()>¶

clear_after = False¶

install()[исходный код]¶

on_cleanup()[исходный код]¶

on_shutter(state)[исходный код]¶

shutter()[исходный код]¶

shutter_signal = <Signal: shutter_signal providing_args={'state'}>¶

timer = None¶

celery.events.snapshot.evcam(camera, freq=1.0, maxrate=None, loglevel=0, logfile=None, pidfile=None, timer=None, app=None, **kwargs)[исходный код]¶

Start snapshot recorder.