celery_beat_periodic_task_scheduling_every_30_seconds.py

1from celery import Celery
2from celery.schedules import crontab
3
4app = Celery('tasks', broker='pyamqp://guest@localhost//')
5
6@app.task
7def see_you_space_cowboy():
8    print("See you space cowboy...")
9
10app.conf.beat_schedule = {
11    # Executes every 30 seconds
12    'add-every-30-seconds': {
13        'task': 'tasks.see_you_space_cowboy',
14        'schedule': 30.0,
15        'args': ()
16    },
17}
18
19if __name__ == '__main__':
20    app.start()