Ubuntu 安装celery

如何在 Ubuntu 上安装 Celery 分布式任务队列
安装 Python 及虚拟环境工具
为了确保项目的依赖项不会影响其他项目，在开始之前建议创建一个新的虚拟环境。
sudo apt-get update
sudo apt-get install python3-pip python3-dev build-essential libssl-dev libffi-dev python3-setuptools
pip3 install virtualenv
virtualenv venv
source venv/bin/activate
登录后复制
使用 pip 安装 Celery
激活虚拟环境之后，可以通过 pip 来安装最新版本的 Celery：
pip install celery
登录后复制
配置消息代理（Broker）
Celery 支持多种消息代理[^2]。最常用的配置方式之一是使用 Redis 或 RabbitMQ 作为 Broker。这里以 Redis为例说明如何设置:
安装 Redis Server
sudo apt-get install redis-server
登录后复制
确认Redis服务已经启动：
sudo systemctl status redis.service
登录后复制
如果未启动，则可通过命令 sudo systemctl start redis 启动它。
创建第一个 Celery 应用程序
建立一个简单的 Celery 实例文件 structure，比如命名为 myproject/celery_worker.py :
from celery import Celery

app = Celery('myproject',
broker='redis://localhost:6379/0')

@app.task
def add(x, y):
return x + y
登录后复制
上述代码定义了一个名为 add 的简单任务函数，并指定了使用的 Broker URL[^1]。
运行 Worker
进入包含此脚本的目录并运行如下命令来启动 worker：
celery -A myproject.celery_worker worker --loglevel=info
登录后复制
这将会启动一个监听来自指定 Broker 新任务的工作进程。
测试任务调度
可以利用 Python Shell 发送测试任务给刚才启动的服务端点：
>>> from myproject.celery_worker import add
>>> result = add.delay(4, 5)
>>> print(result.get())
9
登录后复制
以上就是在 Ubuntu 系统上部署基本版 Celery 的过程概述。对于生产环境中更复杂的场景可能还需要考虑更多因素如安全性、持久化存储等。