没有得到如何使用redis和芹菜

Question

我是新来的redis和celery.我已经通过了两者的基本教程.但我没有得到如何实施task scheduling job

Answer 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'将出现在控制台中.

这是如何设置任务执行环境的基本示例.