Как периодически планировать задание django celery

Question

# In tasks.py file 
from __future__ import absolute_import 

from celery import shared_task 

@shared_task 
def randadd(x): 
    y = randint(0,9) 
    return x + y 

# In views.py 
    context = { 
     'add': tasks.randadd(5) 
    } 
def home(request): 
    global context 
    return render(request, "home.html", context) 

# In home.html 
<h1>{{ add }}</h1> 

В home.html Я вижу результат 5 + (случайный int). Как бы я пересчитал результат для добавления, чтобы его значение обновлялось каждые 30 минут?

Я смог найти этот источник: http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html, но я все еще смущен тем, как его использовать.

Answer 1

Вот реализация оболочки с использованием Redis в качестве хранилища данных. Предполагается, что Redis установлен и запущен на локальном компьютере с настройками по умолчанию.

# tasks.py 
import redis 
from celery import shared_task 

@shared_task 
def update_number(): 
    r = redis.StrictRedis() 
    r.set('my_number', randint(0,9)) 


# views.py 
import redis 

def home(request): 
    r = redis.StrictRedis() 
    context = { 
     'add': r.get('my_number') 
    } 
    return render(request, 'home.html', context) 


# settings.py 
from celery.schedules import crontab 

CELERYBEAT_SCHEDULE = { 
    'context': { 
     'task': 'tasks.update_number', 
     'schedule': crontab(minute=30), 
    } 
} 

Обязательно проверьте сельдерей документы на следующие:

• Настройки очереди сообщений (Redis может быть использован в качестве очереди сообщений)
• Run сельдерея рабочего
• Выполнить Пример использования сельдерея:

Answer 2

На основе документации вы ссылочных, это выглядит, как это один из способов:

from celery.schedules import crontab 

CELERYBEAT_SCHEDULE = { 
    'context': { 
     'task': 'randadd', 
     'schedule': crontab(minute=30), 
     'args': 5 
     # or if that doesn't work try: 
     #'args':(5) 
    }, 
} 

И это еще одна:

from datetime import timedelta 

CELERYBEAT_SCHEDULE = { 
    'context': { 
     'task': 'tasks.add', 
     'schedule': timedelta(minutes=30), 
     'args': 5 
     #but the last line still might be: 
     #'args':(5) 
    }, 
}