celery_redbeat_dynamic_periodic_task_scheduler_redis_backend.py

1from celery import Celery
2from celery.schedules import crontab
3from redbeat import RedBeatSchedulerEntry
4
5app = Celery('tasks', broker='redis://localhost:6379/0')
6
7# Configure RedBeat settings
8app.conf.update(
9    redbeat_redis_url="redis://localhost:6379/1",
10    beat_scheduler='redbeat.RedBeatScheduler',
11    result_backend='redis://localhost:6379/0'
12)
13
14@app.task
15def hello(name):
16    return f"Hello {name}"
17
18# Example of adding a task dynamically
19entry = RedBeatSchedulerEntry('hello-every-5-minutes', 'tasks.hello', crontab(minute='*/5'), args=['world'], app=app)
20entry.save()