网站基本框架就是有2个定时任务。第一个定时任务会从mysql里面根据当前登录用户id取得其数据表A里面的值，然后进行一些逻辑计算，然后发起网络请求。第二个定时任务也是这样，只是要将计算结果存入mysql数据库。
django项目的结构和这里的一样。项目名称是proj 。app名称是demoapp
http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html#using-celery-with-django
settings.py 里面加了下面的代码
from datetime import timedelta
CELERYBEAT_SCHEDULE = {
'add-every-30-seconds': {
'task': 'tasks.add',
'schedule': timedelta(seconds=6),
'args': (1,2)
},
}
celery的broker和backend都是用的redis。
然后运行celery -A proj worker -l info开启队列
然后运行celery -A proj beat开启定时任务。
但是开启定时后，总是说我Received unregistered task of type 'tasks.add'.
难道是我setting里面的设置问题吗？我没有用django-celery
django项目的结构和这里的一样。项目名称是proj 。app名称是demoapp
http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html#using-celery-with-django
settings.py 里面加了下面的代码
from datetime import timedelta
CELERYBEAT_SCHEDULE = {
'add-every-30-seconds': {
'task': 'tasks.add',
'schedule': timedelta(seconds=6),
'args': (1,2)
},
}
celery的broker和backend都是用的redis。
然后运行celery -A proj worker -l info开启队列
然后运行celery -A proj beat开启定时任务。
但是开启定时后，总是说我Received unregistered task of type 'tasks.add'.
难道是我setting里面的设置问题吗？我没有用django-celery
1
Select Language