Python开发运维：Celery连接Redis
from celery import Celery
# 创建Celery实例，指定Broker为Redis
app = Celery('tasks', broker='redis://localhost:6379/0')
# 定义一个Celery任务
@app.task
def add(x, y):
return x + y
# 使用Celery任务
result = add.delay(4, 4)
print(result.result) # 输出任务执行结果这段代码演示了如何使用Celery连接Redis，并定义了一个简单的加法任务。首先，我们创建了一个Celery实例，指定了Broker为Redis，并且提供了Redis的URL和指定的数据库（这里是localhost上的第0个数据库）。然后，我们定义了一个名为add的任务，该任务会异步执行加法操作。最后，我们启动了一个任务并打印了其结果。这个例子简单明了地展示了如何使用Celery和Redis进行异步任务队列的管理和执行。
评论已关闭