2
你好朋友,我需要你的幫助,在django應用程序的定期任務中。我正在嘗試使用芹菜進行定期任務,但它不能正常工作。我有一個簡單的任務,其中只有一個打印語句。芹菜工作只適用於第一時間,我也試過「芹菜拍」,但沒有得到結果定期任務在django芹菜中不能正常工作
我「task.py」是
from __future__ import absolute_import
from myapp.celery import app
from celery.schedules import crontab
from celery.task import periodic_task
from celery.registry import tasks
@periodic_task(run_every=(crontab(minute='*/1')), name="some_task")
def every_minute(a,b):
print("This is running after one minute",a+b)
return "task done"
tasks.register(every_minute)
和「view.py」
from django.http import HttpResponse
from django.views.generic import View
from .tasks import *
from .models import *
from datetime import datetime, timedelta
class CeleryTest(View):
def get(self,request):
send_date = datetime.now() + timedelta(seconds=200)
task=every_minute.apply_async([5,6],etc=send_date)
while not task.ready():
print "calling............task is not ready"
return HttpResponse("hi get ur task")
我只是在前面芹菜設定加入此計劃。「setting.py」
CELERYBEAT_SCHEDULE = {
'every_minute': {
'task': 'every_minute.add',
'schedule': crontab(minute='*/1'),
'args': (5, 6),
},
}
謝謝各位朋友的時間。