celery.apps.beat

celery.apps.beat

This module is the ‘program-version’ of celery.beat.

It does everything necessary to run that module as an actual application, like installing signal handlers and so on.

class celery.apps.beat.Beat(max_interval=None, app=None, socket_timeout=30, pidfile=None, no_color=None, loglevel=None, logfile=None, schedule=None, scheduler_cls=None, redirect_stdouts=None, redirect_stdouts_level=None, ***kwargs*)[源代码]

  • class Service(app, max_interval=None, schedule_filename=None, scheduler_cls=None)

  • get_scheduler(lazy=False)

  • scheduler None
  • scheduler_cls

    PersistentScheduler 的别名 - start(embedded_process=False) - stop(wait=False) - sync() - Beat.app = None - Beat.init_loader()[源代码] - Beat.install_sync_handler(beat)[源代码]

Install a SIGTERM + SIGINT handler that saves the beat schedule. - Beat.run()[源代码] - Beat.set_process_title()[源代码] - Beat.setup_logging(colorize=None)[源代码] - Beat.start_scheduler()[源代码] - Beat.startup_info(beat)[源代码]