blocks|key|966937|text|rabbitmqadmin就是最好的工具|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|966938|rabbitmqadmin+purge+queue+name=name_of_the_queue_to_be_purged|code-block|syntax|javascript|966939|entityMap|0|LINK|mutability|MUTABLE|url|http://www.rabbitmq.com/management-cli.html^0|0|D|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

<a href="http://www.rabbitmq.com/management-cli.html" rel="noreferrer">rabbitmqadmin</a> is the perfect tool for this

<pre><code>rabbitmqadmin purge queue name=name_of_the_queue_to_be_purged
</code></pre>

blocks|key|751708|text|您可以直接运行此命令|type|unstyled|depth|inlineStyleRanges|entityRanges|data|751709|sudo+rabbitmqctl+purge_queue+queue_name|code-block|syntax|javascript|751710|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

you can directly run this command

<pre><code>sudo rabbitmqctl purge_queue queue_name
</code></pre>

blocks|key|751597|text|刷新queue可以使用如下命令(详见API文档)：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|751598|curl+-i+-u+guest:guest+-XDELETE+http://localhost:15672/api/queues/vhost_name/queue_name/contents|code-block|syntax|javascript|751599|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

To purge queue you can use following command (more information in API doc):

<pre><code>curl -i -u guest:guest -XDELETE http://localhost:15672/api/queues/vhost_name/queue_name/contents
</code></pre>

blocks|key|751681|text|RabbitMQ实现了高级消息队列协议(AMQP)，因此您可以使用通用工具来完成这类工作。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|751682|在Debian/Ubuntu或类似系统上，执行以下操作：|751683|sudo+apt-get+install+amqp-tools
amqp-delete-queue+-q+celery++#+where+celery+is+the+name+of+the+queue+to+delete|code-block|syntax|javascript|751684|entityMap^0|0|0|0^^$0|@$1|2|3|4|5|6|7|K|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|L|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|M|8|@]|9|@]|A|$G|H]]|$1|I|3|-4|5|6|7|N|8|@]|9|@]|A|$]]]|J|$]]

RabbitMQ implements the Advanced Message Queuing Protocol (AMQP) so you can use generic tools for stuff like this.

On Debian/Ubuntu or similar system, do:

<pre><code>sudo apt-get install amqp-tools
amqp-delete-queue -q celery # where celery is the name of the queue to delete
</code></pre>

blocks|key|966972|text|重要提示:这将删除所有用户和配置。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|966973|注意!！|966974|966975|除非您想从所有队列中删除数据，包括用户和配置，否则我不建议使用此答案。重置它！|966976|rabbitmqctl+stop_app
rabbitmqctl+reset
rabbitmqctl+start_app|code-block|syntax|javascript|966977|entityMap^0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|N|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|O|8|@]|9|@]|A|$]]|$1|D|3|C|5|6|7|P|8|@]|9|@]|A|$]]|$1|E|3|F|5|6|7|Q|8|@]|9|@]|A|$]]|$1|G|3|H|5|I|7|R|8|@]|9|@]|A|$J|K]]|$1|L|3|-4|5|6|7|S|8|@]|9|@]|A|$]]]|M|$]]

IMPORTANT NOTE: This will delete all users and config.

ALERT !!

ALERT !!

I don't suggest this answer until unless you want to delete data from all of the queues, including users and configs.
Just Reset it !!!

<pre><code>rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
</code></pre>

blocks|key|751652|text|我想已经很晚了，但对于其他人来说，这可以用pika来完成。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|751653|import+pika
host_ip+=+#host+ip
channel+=+pika.BlockingConnection(pika.ConnectionParameters(host_ip,
++++++++++++++++++++++++++++++++++++++++++++++++++++++++5672,
++++++++++++++++++++++++++++++++++++++++++++++++++++++++"/",
credentials=pika.PlainCredentials("username","pwd"))).channel()
print+"deleting+queue..",+channel.queue_delete(queue=queue_name)|code-block|syntax|javascript|751654|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I guess its late but for others reference, this can be done with pika

<pre><code>import pika
host_ip = #host ip
channel = pika.BlockingConnection(pika.ConnectionParameters(host_ip,
 5672,
 "/",
credentials=pika.PlainCredentials("username","pwd"))).channel()
print "deleting queue..", channel.queue_delete(queue=queue_name)
</code></pre>

blocks|key|967030|text|我已经成功地使用了amqp-utils中的ampq-purge来完成此操作：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|967031|git+clone+https://github.com/dougbarth/amqp-utils.git
cd+amqp-utils
#+extracted+from+Rakefile
echo+"source+'https://rubygems.org'
gem+'amqp',+'~>+0.7.1'
gem+'trollop',+'~>+1.16.2'
gem+'facets',+'~>+2.9'
gem+'clio',+'~>+0.3.0'
gem+'json',+'~>+1.5'
gem+'heredoc_unindent',+'~>+1.1.2'
gem+'msgpack',+'~>+0.4.5'"+>+Gemfile
bundle+install+--path=$PWD/gems
export+RUBYLIB=.
export+GEM_HOME=$PWD/gems/ruby/1.9.1

ruby+bin/amqp-purge+-v+-V+/vhost+-u+user+-p+queue
#+paste+password+at+prompt|code-block|syntax|javascript|967032|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/dougbarth/amqp-utils^0|L|A|9|A|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@$9|T|A|U|B|C]]|D|@$9|V|A|W|1|X]]|E|$]]|$1|F|3|G|5|H|7|Y|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|Z|8|@]|D|@]|E|$]]]|L|$M|$5|N|O|P|E|$Q|R]]]]

I have successfully used <code>ampq-purge</code> from <a href="https://github.com/dougbarth/amqp-utils" rel="nofollow">amqp-utils</a> to do this:

<pre><code>git clone https://github.com/dougbarth/amqp-utils.git
cd amqp-utils
# extracted from Rakefile
echo "source 'https://rubygems.org'
gem 'amqp', '~&gt; 0.7.1'
gem 'trollop', '~&gt; 1.16.2'
gem 'facets', '~&gt; 2.9'
gem 'clio', '~&gt; 0.3.0'
gem 'json', '~&gt; 1.5'
gem 'heredoc_unindent', '~&gt; 1.1.2'
gem 'msgpack', '~&gt; 0.4.5'" &gt; Gemfile
bundle install --path=$PWD/gems
export RUBYLIB=.
export GEM_HOME=$PWD/gems/ruby/1.9.1

ruby bin/amqp-purge -v -V /vhost -u user -p queue
# paste password at prompt
</code></pre>

blocks|key|967159|text|我的rabbitmqclt是一个没有purge_queue的旧版本，而且我没有安装rabbitmqadmin。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|967160|我们的应用程序在芹菜上运行，它有这样的命令：|967161|celery+-A+<app_name>+-Q+<queue_name>+purge|code-block|syntax|javascript|967162|entityMap^0|2|B|15|D|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]|$9|R|A|S|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|T|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|U|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|V|8|@]|D|@]|E|$]]]|N|$]]

My <code>rabbitmqclt</code> was an older version without purge_queue, and I did not have <code>rabbitmqadmin</code> installed.
Our app runs on celery and it has this command that worked:
<pre><code>celery -A &lt;app_name&gt; -Q &lt;queue_name&gt; purge
</code></pre>

How do I delete all messages from a single queue using the cli?
I have the queue name and I want to clean it.

How do I delete all messages from a single queue using the CLI?

消息队列

Ubuntu

Debian

如何使用cli从单个队列中删除所有消息？我有队列名称，我想要清理它。

问如何使用CLI删除单个队列中的所有消息？
EN

回答 8

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用CLI删除单个队列中的所有消息？EN

回答 8

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用CLI删除单个队列中的所有消息？
EN