[ Tool ] celery分布式任务框架基本使用
warning:
这篇文章距离上次修改已过201天，其中的内容可能已经有所变动。
from celery import Celery
# 创建Celery实例
app = Celery('my_task', broker='redis://localhost:6379/0')
# 定义一个Celery任务
@app.task
def add(x, y):
return x + y
# 使用Celery任务
result = add.delay(4, 4)
print(result.result) # 输出: 8这段代码演示了如何使用Celery创建一个简单的分布式任务。首先，我们创建了一个Celery实例，指定了要使用的消息代理（这里是Redis）。然后，我们定义了一个名为add的任务，该任务接受两个参数并返回它们的和。最后，我们调用add.delay()来异步执行任务，并打印出结果。这个例子简单明了地展示了Celery的基本使用方法。
评论已关闭