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”将出现在控制台中。

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