celery.py app.conf.beat_schedule = {
'find_min_price': {
'task': 'shop.views.price',
'schedule': crontab(minute='*/5'),
},
'reiting': {
'task': 'shop.views.rank',
'schedule': crontab(minute='*/5'),
},
} views.py @app.task
def price():
obj = Store()
cron_tasks = obj.search_min_price()
@app.task
def rank():
obj = Store()
cron_tasks = obj.reiting()
Вообще плохая практика во вьюхи таски запихивать. Но судя по коду одинаково работают таски.
Обсуждают сегодня