celery 使用示例

当然，我可以给你一个简单的 Celery 使用示例。Celery 是一个强大的分布式任务队列框架，常用于处理异步任务和定时任务。

首先，你需要安装 Celery。你可以使用 pip 命令来安装：

pip install celery

接下来，创建一个 Celery 应用。在你的项目中创建一个名为 `tasks.py` 的文件，并添加以下内容：

from celery import Celery

# 创建 Celery 应用
app = Celery('tasks', broker='redis://localhost:6379/0')

# 定义任务
@app.task
def add(x, y):
    return x + y

这里我们使用了 Redis 作为消息代理（broker），你也可以选择其他的消息代理，比如 RabbitMQ。

接下来，在你的项目根目录下创建一个名为 `celery_worker.py` 的文件，并添加以下内容：

from tasks import app

# 启动 Celery 工作进程
if __name__ == '__main__':
    app.worker_main()

现在，你可以启动 Celery 工作进程了。打开终端，进入你的项目根目录，运行以下命令：

celery -A celery_worker worker --loglevel=info

这样，Celery 工作进程就会启动并开始监听任务了。

最后，你可以在你的代码中调用 `add` 任务，示例如下：

from tasks import add

result = add.delay(4, 6)  # 异步调用任务
print(result.get())  # 获取任务结果

这样就完成了一个简单的 Celery 使用示例。你可以根据自己的需求定义更多的任务，并在你的代码中调用它们。希望对你有帮助！