使用 MongoDB 作为 Celery 的消息队列答案

【问题标题】：Using MongoDB as message queue for Celery使用 MongoDB 作为 Celery 的消息队列
【发布时间】：2011-01-24 19:13:41
【问题描述】：

我正在尝试使用 MongoDB 作为 Celery 的消息队列（在 Django 应用程序中）。当前的 Celery 开发版本 (2.2.0rc2) 应该可以让您执行此操作，但我似乎无法让任何工作人员接手我正在创建的任务。

版本：芹菜 v2.2.0rc3
MongoDB 1.6.5
pymongo 1.9
django-celery 2.2.0rc2

在我的设置中，我有：

CELERY_RESULT_BACKEND = "mongodb"
CELERY_MONGODB_BACKEND_SETTINGS = {
    # Shouldn't need these - defaults are correct.
    "host": "localhost",
    "port": 27017,
    "database": "celery",
    "taskmeta_collection": "messages",
}

BROKER_BACKEND = 'mongodb'
BROKER_HOST = "localhost"
BROKER_PORT = 27017
BROKER_USER = ""
BROKER_PASSWORD = ""
BROKER_VHOST = ""

import djcelery
djcelery.setup_loader()

我创建了一个测试tasks.py文件如下：

from celery.decorators import task

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

如果我在后台启动 celeryd，它似乎可以正常启动。然后我打开一个 python shell 并运行以下命令：

>>> from myapp.tasks import add
>>> result = add.delay(5,5)
>>> result
<AsyncResult: 7174368d-288b-4abe-a6d7-aeba987fa886>
>>> result.ready()
False

问题是没有工人接手任务。我错过了一个设置还是什么？如何将 celery 指向消息队列？

【问题讨论】：

该应用是否在已安装的应用中？如果有的话，芹菜在其原木中返回的是什么？ .ready() 在不应该返回 False 的一个常见原因是因为任务未被识别，Celery 会说类似“未知任务被忽略：......”
你有没有得到这个工作？我也有同样的问题
很遗憾，我没有。
调用“result.get()”时会发生什么（也可以从“result.result”检查worker是否抛出异常

标签： django mongodb message-queue rabbitmq celery

【解决方案1】：

我们遇到了同样的问题。虽然文档说所有任务都应该通过调用

在 Celery 中注册

import djcelery
djcelery.setup_loader()

它没有正常工作。所以，我们还是用了

CELERY_IMPORTS = ('YOUR_APP.tasks',)

settings.py 中的设置。另外，如果添加新任务，请确保重新启动 Celery，因为 Celery 必须在首次启动时注册任务。

Django, Celerybeat and Celery with MongoDB as the Broker

【讨论】：

【解决方案2】：

请记住，Kombu 仅适用于 mongo 1.3+，因为它需要 findandmodify 功能。如果您在 ubuntu 上，存储库中的最后一个版本是 1.2，则不起作用。

也许你还需要设置 BROKER_VHOST = "数据库名"

如果可行，请随时通知我

【讨论】：

【解决方案3】：

请务必将此添加到您的设置中，否则工作人员找不到任务并会静默失败。

CELERY_IMPORTS = ("namespace", )

【讨论】：

【解决方案4】：

我遇到了同样的问题，但是当我升级到 celery 2.3.3 时，一切都像魅力一样。

【讨论】：