我有兴趣尝试 Celery 用于 python 的分布式任务队列。
在我们的场景中,我们有多个分支,每个分支都会运行一个 RabbitMQ 服务器,我希望能够在分支之间执行任务。
例如,在带有 RabbitMQ 实例 C 的分支 AI 队列任务 B 中。现在需要发生的是,任务 B 从实例 C 转发到在另一个分支 E 中运行的 RabbitMQ 实例 D。在分支 E 中,一个工作进程拿起任务,响应完成后返回等。
互联网上是否有示例概述了如何设置它,或者您知道这是否有效?
看起来 RabbitMQ 的 Federation / Shovel 特性是要走的路,但想知道是否有人在这种情况下使用过 Celery / RabbitMQ?
非常感谢,帕特里克