1、安装django-celery-beat

2、windows下安装redis server,win+r启动redis server: redis-server redis.windows.conf

3、在app/tasks.py中添加定时方法

  1. from celery import shared_task
  2. @shared_task
  3. def test_beat(x, y):
  4. print(x+y)

4、在mysite/settings.py中添加:

  1. from datetime import timedelta
  2. # 定时任务
  3. CELERYBEAT_SCHEDULE = {
  4. 'add-every-30-seconds':{
  5. 'task': 'home.tasks.test_beat', # 任务名
  6. 'schedule': timedelta(seconds=2), # 每2s执行一次该任务
  7. 'args': (2, 3)
  8. }
  9. }

新增任务时,可类似继续添加

5、启动worker、beat

celery -A mysite worker -l info -P eventlet

celery -A mysite beat -l info

6、结果:

 

版权声明:如无特殊说明,文章均为本站原创,转载请注明出处

本文链接:http://wakemeupnow.cn/article/django/