Django AMQP 错误

Question

我安装了一个 Django 应用程序，可以将任务发送到 Celery，并且在我的 settings.py 中有以下内容文件:

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "user"
BROKER_PASSWORD = "password"
BROKER_VHOST = "host"
BROKER_BACKEND = "amqp"
...
CELERY_ALWAYS_EAGER = False

我运行服务器，一切似乎都很好，直到我真正去运行任务。我收到以下错误:

Exception Type:     KeyError
Exception Value:   'No such transport: amqp'

我安装了 AMQP 库并列在我的站点包目录中，但我找不到有关此错误的任何信息...？

Answer 1

昆布的问题

pip install celery kombu==2.4.0

Celery Error 'No such transport: amqp'