0

我正在努力将带有 Kombu 的消息传递系统放在一起,但我遇到了以下问题。假设我有消息被路由到路由键“x”和“y”。这在“x”和“y”之间没有依赖关系的情况下非常有用。

但是,考虑另一种情况,我将数据发送到路由键“a”、“b”和“c”,并且单个队列正在从这些路由键中获取消息。如果我需要来自 a、b 和 c 的数据一起处理单个回调,有没有办法将这些消息聚合到单个工作线程中,或者这是消息传递范式的完全混蛋?

我知道我可以将消息缓存在其他地方(例如,Redis),并且仅在我拥有必要的数据时才进行处理,但我想知道 Kombu 是否可以做到这一点,而不必每次都缓存数据并唤醒工作人员。感谢您的任何建议;如果有帮助,我可以给出一些代码示例。

4

0 回答 0