RabbitMQ 和 Celery 的新手问题

Question

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

我已经添加了我的rabbitmq 用户、虚拟主机并设置了我的权限。 启动了我的 RabbitMQ 服务器

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

Rich Leland 的详细教程

你是否还需要芹菜，或者我采取的步骤是否足够？

我在任何地方都没有看到任何关于此的信息或注释......只是问

Answer 1

好吧，您需要运行某种 celery 进程才能处理队列中的任务。 celeryd 进程监听队列，并根据您的设置执行任务。如果您没有运行 celeryd 进程，您只需将任务添加到队列中，但永远不会清空它。

如果您只是想查看队列，我建议您安装 RabbitMQ 管理插件。

Answer 2

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

1. 启动 RabbitMQ 服务器
2. 定义 celeryconfig.py
3. 启动 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() 

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

celeryd --loglevel=INFO

最后，运行tasks.py