redis和芹菜实例

Question

我对redis和celery不熟悉。我已经看过了这两种方法的基本教程，但在task scheduling job中我还不知道如何实现它们

我无法从脚本部分开始。我不知道如何编写一个脚本，使队列，运行工人等，我需要一个实际的例子

Answer 1

所以这里有一个canonical示例来说明celery如何与Redis一起运行（让脚本文件名为我的任务.py)公司名称：

from celery import Celery

celery = Celery('tasks', broker='redis://localhost:6379/0')

@celery.task
def add(x, y):
    return x + y

如您所见，broker参数被设置为使用本地计算机上安装的Redis。下一步是启动celery服务器：

^{pr2}$

由于tasks celery服务器已经启动，现在只需导入mytasks脚本即可使用它来运行任务，例如从Python解释器交互模式：

>>> from mytasks import add
>>> add.delay(1, 1)
2

控制台中的某个时间后将出现。在

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