如何在Linux上安装Celery

avatar
作者
筋斗云
阅读量:0

在 Linux 上安装 Celery,您需要遵循以下步骤:

  1. 首先,确保已经安装了 Python 和 pip。您可以使用以下命令检查它们是否已安装:
python --version pip --version 

如果没有安装,请使用以下命令安装 Python 和 pip:

# 对于 Ubuntu/Debian 系统 sudo apt-get update sudo apt-get install python python-pip  # 对于 CentOS/RHEL 系统 sudo yum install python python-pip 
  1. 接下来,使用 pip 安装 Celery:
pip install celery 
  1. (可选)为了更好地管理 Celery 任务,您还可以安装一个消息代理,例如 RabbitMQ 或 Redis。这里我们以安装 RabbitMQ 为例:
# 对于 Ubuntu/Debian 系统 echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list > /dev/null wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add - sudo apt-get update sudo apt-get install rabbitmq-server sudo systemctl enable rabbitmq-server sudo systemctl start rabbitmq-server  # 对于 CentOS/RHEL 系统 sudo yum install epel-release sudo yum install rabbitmq-server sudo systemctl enable rabbitmq-server sudo systemctl start rabbitmq-server 
  1. 现在,您已经在 Linux 上成功安装了 Celery。接下来,您可以开始创建 Celery 任务并运行它们。以下是一个简单的示例:
from celery import Celery  app = Celery('tasks', broker='pyamqp://guest@localhost//')  @app.task def add(x, y):     return x + y 
  1. 要运行 Celery worker,请在命令行中输入以下命令:
celery -A tasks worker --loglevel=info 
  1. 最后,您可以通过调用 add.delay() 方法将任务添加到队列中:
result = add.delay(4, 4) print(result.get())  # 输出:8 

现在,您已经在 Linux 上安装了 Celery,并成功运行了一个简单的任务。您可以根据需要创建更多复杂的任务并运行它们。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!