Jak usunąć wszystkie wiadomości z pojedynczej kolejki przy użyciu interfejsu wiersza polecenia?

142

Jak usunąć wszystkie wiadomości z jednej kolejki za pomocą CLI? Mam nazwę kolejki i chcę ją wyczyścić.

rabbitmq

— Bick
źródło

121

Rabbitmqadmin jest do tego idealnym narzędziem

rabbitmqadmin purge queue name=name_of_the_queue_to_be_purged

— pr4n
źródło

5

Trudno mi było znaleźć narzędzie w mojej instalacji rabbitmq. W końcu pobrałem

— FactualHarmony

5

Jeśli masz już zainstalowaną wtyczkę do zarządzania, możesz ją pobrać zhttp://rabbitserver:15672/cli/

— morloch,

140

możesz bezpośrednio uruchomić to polecenie

sudo rabbitmqctl purge_queue queue_name

— Anurag jain
źródło

15

lub, jeśli masz wirtualnego hosta, zrób torabbitmqctl purge_queue queue_name -p my_virt_host

— goat

4

uruchom sudo rabbitmqctl -h i sprawdź listę camm na liście twojego aktualnego rabbitmq. jeśli go tam nie ma, oznacza to, że aktualna wersja rabbitmq nie obsługuje tej funkcji.

— Anurag jain

To nie zadziałało - jak tylko mój konsument odpalił, kolejka wciąż była pełna zadań.

— Jamie Ivanov

Mogło to zostać zaimplementowane w 3.5.4 lub 3.6.0, na podstawie github.com/rabbitmq/rabbitmq-server/pull/215 i rabbitmq.com/changelog.html . Jeśli masz starszą wersję, może pomóc rabbitmqadmin zgodnie ze stackoverflow.com/a/18267342/272387 .

— Richlv,

1

... i sprawdzając na github.com/rabbitmq/rabbitmq-server/releases/tag/ ... ta funkcja pojawiła się w 3.5.4.

— Richlv

16

Aby wyczyścić kolejkę, możesz użyć następującego polecenia (więcej informacji w dokumentacji API):

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

— Olga
źródło

Trochę przerażające, jak dobrze to działało. Jakiś sposób, aby się przed tym nieumyślnie uchronić? Na przykład konfiguracja dla serwerów produkcyjnych, która wyłącza tę funkcję, aby zapobiec przypadkowej utracie danych?

— Izajasz

Tak, ochrona polegałaby na usunięciu użytkownika „guest” za pomocą polecenia „delete_user”

— Ocean Airdrop

16

RabbitMQ implementuje protokół Advanced Message Queuing Protocol (AMQP), dzięki czemu można używać ogólnych narzędzi do takich rzeczy.

W systemie Debian / Ubuntu lub podobnym wykonaj:

sudo apt-get install amqp-tools
amqp-delete-queue -q celery  # where celery is the name of the queue to delete

— benjaoming
źródło

To dobre rozwiązanie dla niektórych wersji, które nie mają rabbitmqadmin.

— WisZhou

11

Spowoduje to usunięcie całej kolejki, a nie tylko jej wyczyszczenie. Tak więc kolejka już nie istnieje i musisz później ponownie zainicjować pustą kolejkę.

— krob

13

RabbitMQ ma 2 rzeczy w kolejce

Usunąć
Oczyścić

Usuń - usuwa kolejkę

Wyczyść - spowoduje to opróżnienie kolejki (co oznacza usunięcie wiadomości z kolejki, ale kolejka nadal istnieje)

— Guru Prasad
źródło

1

Może się to wydawać proste, ale to była odpowiedź, której potrzebowałem.

— Nicholas Pickering

8

WAŻNA UWAGA: spowoduje to usunięcie wszystkich użytkowników i config.

ALARM !!

Nie sugeruję tej odpowiedzi, chyba że chcesz usunąć dane ze wszystkich kolejek, w tym użytkowników i konfiguracji. Po prostu zresetuj !!!

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

— naren
źródło

28

To również resetuje twoich użytkowników i inne konfiguracje!

— Codewithcheese

Użyłem tego w ramach testów jednostkowych. np. wyczyszczę wszystko, a następnie ustawiam to wszystko programowo przez stackoverflow.com/questions/4545660/ ... następnie wypełniam kilka wiadomości i wykonuję testy czarnoskrzynkowe, aby upewnić się, że wiadomości przeszły. Świetnie sprawdza się w tym celu. :)

— James Oravec

3

To jest naprawdę naiwne. Nie do przyjęcia jest odpowiedź na poważne pytanie. Zniszczy wszystkie dane serwera.

— Andre Pastore

2

wyzerowanie pamięci i ponowna instalacja systemu operacyjnego również usuwa dane; nie o to prosi OP

— istepaniuk

5

Myślę, że jest późno, ale dla innych odniesień można to zrobić za pomocą pika

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)

— prajnavantha
źródło

1

cześć @prajnavantha czy pika ma jakąś metodę, tylko jasne przesłanie? (nie usuwaj kolejki)

— Jade Han

2

Z powodzeniem użyłem ampq-purgez amqp-utils, aby to zrobić:

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

— andrewdotn
źródło

2

Aby usunąć tylko wiadomości z kolejki, użyj:

sudo rabbitmqctl --node <nodename> purge_queue <queue_name>

Aby usunąć kolejkę, która jest pusta ( --if-empty ) lub nie ma konsumentów ( --if-unused ), użyj:

sudo rabbitmqctl --node <nodename> delete_queue <queue_name> --if-empty

lub

sudo rabbitmqctl --node <nodename> delete_queue <queue_name> --if-unused

— Ashwani Singh
źródło