Sobes.tech
Back to questions
Junior — Middle
54

Для чего используется компонент Celery Beat в системе очередей задач?

Companies where asked
Леста

Answer from AI

sobes.tech AI

Компонент Celery Beat используется для планирования периодических задач в системе очередей Celery. Он работает как планировщик, который по расписанию отправляет задачи в очередь Celery для выполнения.

Основные функции Celery Beat:

  • Позволяет запускать задачи по расписанию (например, каждый час, ежедневно, по определённым дням недели).
  • Хранит расписание задач (может использовать файл, базу данных или другие хранилища).
  • Автоматически отправляет задачи в очередь Celery в нужное время.

Пример использования:

from celery import Celery
from celery.schedules import crontab

app = Celery('tasks', broker='redis://localhost')

app.conf.beat_schedule = {
    'task-every-minute': {
        'task': 'myapp.tasks.my_task',
        'schedule': crontab(minute='*/1'),
    },
}

@app.task
def my_task():
    print('Задача выполнена')

Здесь Celery Beat будет запускать my_task каждую минуту, отправляя её в очередь для выполнения.