¿Para qué se utiliza el componente Celery Beat en el sistema de colas de tareas?

Компонент 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 каждую минуту, отправляя её в очередь для выполнения.