姜戈芹菜周期性任务

Question

我创建了简单的django项目来了解芹菜周期性任务是如何工作的。名为"proj"的项目有一个应用(名称为"示例"(和一个模型("计数器"(。计数器模型只有一个整数字段名称值。我试图每分钟将计数器的值增加 1，但无法让它工作。我的文件：

芹菜/芹菜.py

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
app = Celery('proj')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

样品/模型.py

from django.db import models

class Counter(models.Model):
value = models.IntegerField(default=0)

示例/视图.py

from django.shortcuts import render
from .models import Counter

def index(request):
value = Counter.objects.get(pk=1).value
return render(request, 'sample/index.html', {'value': value})

项目/任务.py

from celery.schedules import crontab
from proj.celery import app
from .models import Counter

@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(
crontab('*', '*', '*', '*', '*'),
my_task())

@app.task
def my_task():
counter = Counter.objects.get(pk=1)
counter.value += 1
counter.save()

我错过了什么？

Answer 1

您必须添加任务并在设置文件中注册。

https://medium.com/@yehandjoe/celery-4-periodic-task-in-django-9f6b5a8c21c7

CELERY_BEAT_SCHEDULE = {
'task-number-one': {
'task': 'app1.tasks.task_number_one',
'schedule': crontab(minute=59, hour=23)
},
'task-number-two': {
'task': 'app2.tasks.task_number_two',
'schedule': crontab(minute=0, hour='*/3,10-19')
}
}