【云原生 | 28】Docker运行分布式任务处理平台Celery
# 安装所需的依赖
# pip install celery[redis]
from celery import Celery
# 创建Celery实例，指定Redis作为消息代理
app = Celery('tasks', broker='redis://localhost:6379/0')
# 定义一个Celery任务
@app.task
def add(x, y):
return x + y
# 如果是作为脚本运行，启动Celery工作者
if __name__ == '__main__':
app.start()这段代码演示了如何使用Celery创建一个简单的分布式任务队列。首先，我们创建了一个Celery实例，指定了使用Redis作为消息代理。然后，我们定义了一个名为add的任务，该任务接受两个参数并返回它们的和。最后，如果这个脚本是直接运行的，我们会启动Celery工作者来处理队列中的任务。这个例子简单而直接，适合作为学习Celery的起点。
评论已关闭