Аз съм нов redis
и celery
, Аз отидох през основния урок на двете. но аз не съм как да се изпълни след това в task scheduling job
Отговори:
6 за отговор № 1Така че тук е каноничен пример за това как може да се използва целина с Redis (нека името на файла на скрипта да бъде mytasks.py):
from celery import Celery
celery = Celery("tasks", broker="redis://localhost:6379/0")
@celery.task
def add(x, y):
return x + y
Както виждате, аргументът на брокера е настроен да използва инсталирания от вас Redis на вашата локална машина. Следващото нещо е да стартирате целина сървър:
$ celery -A mytasks worker --loglevel=info
Тъй като вашите задачи целият сървър е стартиран, вече можете да го използвате, за да изпълнявате задачата си само чрез импортиране на скрипта mytasks, например от интерфейса на интерпретатора на Python:
>>> from mytasks import add
>>> add.delay(1, 1)
2
След известно време в конзолата ще се появи "2".
Това е основен пример за това как можете да настроите средата за изпълнение на задачите си.