queue - 如何在Rabbit MQ中删除队列

Question

我正在使用pika库使用Rabbitmctl。
我使用以下代码创建生产者

#!/usr/bin/env python
import pika
import time
import json
import datetime


connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()



channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    #print " current time: %s "  % (str(int((time.time())*1000)))

    print body

channel.basic_consume(callback,
                      queue='hello',
                      no_ack=True)


channel.start_consuming()

由于我每次都会创建一个现有队列（如果未创建队列，请覆盖创建队列的内容）。由于这个原因，该队列已损坏。现在我要删除该队列。我该怎么做？

Answer 1

由于这似乎是一个维护过程，而不是您对代码进行的例行工作，因此您可能应该使用RabbitMQ management plugin并从此处删除队列。

无论如何，您可以使用以下方法将其从pika中删除：

channel.queue_delete(queue='hello')

https://pika.readthedocs.org/en/latest/modules/channel.html#pika.channel.Channel.queue_delete