使用不同的交换类型动态创建队列

Question

我正在尝试编写一个方法，该方法使用现有交换名称、新队列名称和路由键的参数创建新队列。交换可能有不同的类型（直接、扇出、主题）。

有没有办法在不知道交换类型的情况下制作和绑定队列？

def my_queue(self, exchange_name, queue_name, routing_key):
    with connection.acquire(block=True) as conn:
        ex = Exchange(exchange_name, type='topic')
        queue = Queue(name="my_queue", routing_key="my_key", exchange=ex)
        queue.maybe_bind(conn)
        queue.declare()

Answer 1

考虑到 Celery 通常会自动为您创建队列，您所要做的就是调用 add_consumer() 来订阅（在运行时）一个或多个工作人员到特定队列。如前所述，如果队列不存在，Celery 将为您完成。同样，您可能想要取消订阅队列，在这种情况下您调用cancel_consumer()。