我是 redis
和 celery
的新手。我已经完成了两者的基本教程,但我不知道如何在 task scheduling job
我无法从脚本部分开始。我不知道如何编写脚本来创建队列、运行工作人员等。我需要一个实际示例
最佳答案
所以这是一个典型的例子,说明 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”将出现在控制台中。
这是一个关于如何设置任务执行环境的基本示例。
关于python - redis和celery的实际例子,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/12105388/