Som nový redis
a celery
, Prešiel som základným tutoriálom oboch. ale nedostávam sa do toho, ako sa naplniť task scheduling job
odpovede:
6 pre odpoveď č. 1Takže tu je kanonický príklad toho, ako môže celer bežať s Redisom (nech je názov súboru skriptu mytasks.py):
from celery import Celery
celery = Celery("tasks", broker="redis://localhost:6379/0")
@celery.task
def add(x, y):
return x + y
Ako vidíte, argument makléra bol nastavený na používanie Redis nainštalovaný na vašom lokálnom počítači. Ďalšia vec je spustiť server celeru:
$ celery -A mytasks worker --loglevel=info
Ako ste začali s úlohami celerového servera, teraz ho môžete použiť na spustenie úlohy len importovaním skriptu mytasks, napríklad z interaktívneho režimu interpretov Pythonu:
>>> from mytasks import add
>>> add.delay(1, 1)
2
Po určitom čase sa v konzole objaví „2“.
To je základný príklad toho, ako môžete nastaviť prostredie na vykonávanie úloh.