python - redis和celery的实际例子

Question

我是 redis 和 celery 的新手。我已经完成了两者的基本教程，但我不知道如何在 task scheduling job

中实现

我无法从脚本部分开始。我不知道如何编写脚本来创建队列、运行工作人员等。我需要一个实际示例

Answer 1

所以这是一个典型的例子，说明 celery 如何与 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 服务器:

$ celery -A mytasks worker --loglevel=info

当你的任务 celery 服务器已经启动时，你现在可以使用它来运行你的任务，只需导入 mytasks 脚本，例如从 Python 解释器交互模式:

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

一段时间后，“2”将出现在控制台中。

这是一个关于如何设置任务执行环境的基本示例。