celery_redbeat_scheduler_basic_config_and_task.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# RedBeat configuration
8app.conf.redbeat_redis_url = "redis://localhost:6379/1"
9app.conf.beat_scheduler = 'redbeat.RedBeatScheduler'
10
11@app.task
12def add(x, y):
13    return x + y
14
15# To add a schedule dynamically:
16# entry = RedBeatSchedulerEntry('add-every-30-seconds', 'tasks.add', 30, args=[12, 12], app=app)
17# entry.save()