RabbitMQ去年引入了流。他们声称流可以使用AMQP 0.9和1.0以及这里提到的。也就是说，理论上，我们应该能够创建一个由流支持的队列，将我们需要的尽可能多的工作人员连接到队列，每个工作人员都应该收到消息。
我的问题是，有人试过用芹菜做溪流吗？如果是，请分享有关如何在Celery中配置流的任何信息，以及您迄今为止的使用经验。不幸的是，我找不到关于这个主题的博客文章或任何文档。我希望这篇文章能把所有这些信息放在一个地方。
流的最大优点是，它们允许使用RabbitMQ+Celery的现有基础设施进行大规模扇出。
据我所知，Celery不可能利用流。然而，您可能会启动一个长时间运行的Celery任务来处理特定的流。这可能就是为什么没有人尝试(或者更好地说，记录为博客文章或类似的东西(这样做的原因。-为什么要用芹菜来做一些不适合的东西呢？