芹菜CELERY_DEFAULT_EXCHANGE_TYPE在我运行工人时不起作用

Question

我想在topic模式下运行一些工作线程，所以我更改了CELERY_DEFAULT_EXCHANGE_TYPE设置。

CELERY_DEFAULT_EXCHANGE = 'interesting_exchange'
CELERY_DEFAULT_EXCHANGE_TYPE = 'topic'

当我想向干净的 rabbitmq(假设生产者在消费者之前开始(公开消息时，就像simple_task.apply_async(args=[1, 2, 3])一样，它声明 fine：interesting_exchange声明为主题模式。

但是当我想从一个干净的 rabbitmq(假设消费者在生产者之前启动(运行一个工作线程时，比如celery worker -A celery_app.app，interesting_exchange声明为直接模式。

是否需要指定其他选项？或者它只是一个错误？

Answer 1

这是一个已知的芹菜问题，修复程序已被合并。升级到 Celery 4.4 应该可以解决问题。