celery.beat

Планировщик периодических задач.

celery.beat.EmbeddedService(app, max_interval=None, **kwargs)

Возвращает встроенную службу часов.

Параметры:

thread (bool) – Запуск в отдельном потоке вместо отдельного процесса. По умолчанию используется multiprocessing, если он доступен.

classcelery.beat.PersistentScheduler(*args, **kwargs)

Планировщик, использующий базу данных shelve.

close()

get_schedule()

propertyinfo

known_suffixes=('', '.db', '.dat', '.bak', '.dir')

persistence=<module 'shelve' from '/home/docs/.asdf/installs/python/3.9.22/lib/python3.9/shelve.py'>

propertyschedule

set_schedule(schedule)

setup_schedule()

sync()

classcelery.beat.ScheduleEntry(name=None, task=None, last_run_at=None, total_run_count=None, schedule=None, args=(), kwargs=None, options=None, relative=False, app=None)

Запись в планировщике.

Параметры:

• name (str) – см. name.

• schedule (schedule) – см. schedule.

• args (Tuple) – см. args.

• kwargs (Dict) – см. kwargs.

• options (Dict) – см. options.

• last_run_at (datetime) – см. last_run_at.

• total_run_count (int) – см. total_run_count.

• relative (bool) – Относится ли время к моменту запуска сервера?

args=None

Позиционные аргументы для передачи.

default_now()

editable_fields_equal(other)

is_due()

См. is_due().

kwargs=None

Именованные аргументы для передачи.

last_run_at=None

Дата и время последнего запланированного запуска этой задачи.

name=None

Имя задачи

next(last_run_at=None)

Возвращает новый экземпляр с обновлёнными полями даты и счётчика.

options=None

Параметры выполнения задачи.

schedule=None

Расписание (schedule)

total_run_count=0

Общее количество запланированных запусков этой задачи.

update(other)

Обновляет значения из другой записи.

Обновляются только «редактируемые» поля:

task, schedule, args, kwargs, options.

classcelery.beat.Scheduler(app, schedule=None, max_interval=None, Producer=None, lazy=False, sync_every_tasks=None, **kwargs)

Планировщик периодических задач.

Программа celery beat может создавать экземпляр этого класса несколько раз для анализа, но в этом случае аргумент lazy будет установлен. При установке этого аргумента подклассы должны быть идемпотентными.

Параметры:

• schedule (schedule) – см. schedule.

• max_interval (int) – см. max_interval.

• lazy (bool) – Не настраивать расписание.

Entry

псевдоним для ScheduleEntry

add(**kwargs)

adjust(n, drift=-0.01)

apply_async(entry, producer=None, advance=True, **kwargs)

apply_entry(entry, producer=None)

dl>

close()

propertyconnection

get_schedule()

propertyinfo

install_default_entries(data)

is_due(entry)

logger=<Logger celery.beat (WARNING)>

max_interval=300

Максимальное время ожидания между повторными проверками расписания.

merge_inplace(b)

populate_heap(event_t=<class 'celery.beat.event_t'>, heapify=<built-in function heapify>)

Заполняет кучу данными, содержащимися в расписании.

propertyproducer

reserve(entry)

propertyschedule

Словарь/база shelve с расписанием.

schedules_equal(old_schedules, new_schedules)

send_task(*args, **kwargs)

set_schedule(schedule)

setup_schedule()

should_sync()

sync()

sync_every=180

Как часто синхронизировать расписание (по умолчанию — каждые 3 минуты)

sync_every_tasks=None

Сколько задач может быть вызвано до принудительной синхронизации.

tick(event_t=<class 'celery.beat.event_t'>, min=<built-in function min>, heappop=<built-in function heappop>, heappush=<built-in function heappush>)

Выполняет один такт — одну итерацию планировщика.

За один вызов выполняет одну задачу, время запуска которой наступило.

Возвращает:

рекомендуемую задержку в секундах до следующего вызова.

Тип возвращаемого значения:

float

update_from_dict(dict_)

exceptioncelery.beat.SchedulingError

При планировании задачи произошла ошибка.

classcelery.beat.Service(app, max_interval=None, schedule_filename=None, scheduler_cls=None)

Сервис периодических задач Celery.

get_scheduler(lazy=False, extension_namespace='celery.beat_schedulers')

propertyscheduler

scheduler_cls

псевдоним PersistentScheduler

start(embedded_process=False)

stop(wait=False)

sync()