Celery 错误：kombu.exceptions.NotBoundError：无法在未绑定到通道的 Exchange 上调用方法

Question

我正在使用RabbitMQ 3.6.6和Django 1.10使用芹菜4.0.2，这是我的配置：

from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'my_app.settings')
app = Celery('my_app')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.BROKER_URL = 'amqp://{}:{}@{}'.format(settings.AMQP_USER,  settings.AMQP_PASSWORD, settings.AMQP_HOST)
app.conf.CELERY_DEFAULT_EXCHANGE = 'my_app.celery'
app.conf.CELERY_DEFAULT_QUEUE = 'my_app.celery_default'
app.conf.CELERY_TASK_SERIALIZER = 'json'
app.conf.CELERY_ACCEPT_CONTENT = ['json']
app.conf.CELERY_IGNORE_RESULT = True
app.conf.CELERY_DISABLE_RATE_LIMITS = True
app.conf.BROKER_POOL_LIMIT = 2
app.conf.CELERY_QUEUES = (
    Queue(settings.QUEUE_1),
    Queue(settings.QUEUE_2),
    Queue(settings.QUEUE_3),
)

它可以正常工作，但是当我尝试添加新队列时，即

app.conf.CELERY_QUEUES = (
    Queue(settings.QUEUE_1),
    Queue(settings.QUEUE_2),
    Queue(settings.QUEUE_3),
    Queue(settings.QUEUE_4),
)

我得到此错误：

kombu.exceptions.NotBoundError: Can't call method on Exchange not bound to a channel

如果我删除了其中一个队列，则可以再次工作，因此它似乎仅限于3个队列。我不明白为什么。芹菜是这样发射的：

celery worker -A my_app.celery_app

有什么想法吗？预先感谢！

Answer 1

好吧，这可能是因为我正在使用python 3.6，请参阅：https：//github.com/celery/kombu/issues/675