python-celery专注于实现分布式异步任务处理、任务调度的插件！

作者：System 时间：2024年08月19日分类：所有,分布式字数：625

Celery是一个分布式任务队列，它使得你可以异步地处理大量的任务。Celery通过消息中间件进行通信，比如：RabbitMQ、Redis、MongoDB等。

安装Celery：




pip install celery

下面是一个简单的Celery使用例子：




# tasks.py
from celery import Celery
 
app = Celery('tasks', broker='redis://localhost:6379/0')
 
@app.task
def add(x, y):
    return x + y

在这个例子中，我们定义了一个名为add的异步任务，它接受两个参数并返回它们的和。

要运行Celery任务，你需要启动Celery worker：




celery -A tasks worker --loglevel=info

然后，你可以异步调用add任务：




from tasks import add
 
result = add.delay(4, 4)
print(result.id)  # 打印任务ID

Celery是一个非常强大的工具，可以用于各种场景，包括但不限于：后台任务处理、定时任务调度、时间密集型任务等。