RabbitMQ和芹菜的新手问题

Question

今天早上，我开始尝试使用Celery和RabbitMQ，并定义了一些基本任务，以了解服务器上的性能将如何提高。

我添加了我的rabbitmq用户vhosts并设置了我的权限。启动我的RabbitMQ服务器

在一个非常详细的教程中，我发现这些人使用celerybeat和celeryd来查看某些任务的状态，并执行它们。

the detailed tutorial by Rich Leland

你也需要芹菜吗，或者我已经采取的步骤足够了吗？

我没有看到任何关于这方面的信息或笔记...只是问问

Answer 1

为了处理队列中的任务，您需要运行某种芹菜进程。celeryd进程监听队列，并根据您的设置执行任务。如果您没有运行celeryd进程，那么您只会向队列中添加任务，而不会清空它。

如果您只对查看队列感兴趣，我建议您安装RabbitMQ management plugin。

Answer 2

http://ask.github.com/celery/getting-started/introduction.html

celeryd启动您的celeryconfig.py

• Start服务器

• 定义您的celery守护进程: celeryd

RabbitMQ有一个访客登录，所以这是一种更快的入门方式。将此代码放入celeryconfig.py：

import sys
sys.path.append('.')

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

CELERY_RESULT_BACKEND = "amqp"

CELERY_IMPORTS = ("tasks",)

要快速测试，请将以下代码放入tasks.py：

from celery.task import task

@task
def add(x, y):
    return x + y

if __name__ == "__main__":
    result = add.delay(4, 4)
    result.wait() 

在具有celeryconfig.py和tasks.py的同一目录中启动celeryd：

celeryd --loglevel=INFO

最后，运行tasks.py