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

Question

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

有没有办法在不知道交换类型的情况下创建和绑定(bind)队列？

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() .