指定されたキューを削除して空にする

2年 ago
結衣, 春花
1 minute

RabbitMQの指定したキューを空にするには、RabbitMQの管理プラグインを使用するか、プログラミングで操作する必要があります。

RabbitMQの管理プラグインを使用して指定したキューをクリアする手順：

  1. RabbitMQのManagement Pluginがインストール、有効化されていることを確認して下さい。インストール、有効化されていない場合は、RabbitMQの公式ドキュメントに従ってインストール、有効化を行って下さい。
  2. 通常、RabbitMQの管理インターフェイスを開くには、ブラウザで「 http://localhost:15672 」にアクセスします。
  3. ユーザ名とパスワードを入力して、RabbitMQマネジメント画面にログインする。
  4. 管理画面左側のナビゲーションバーで”Queues”オプションを探しクリックすると、現在すべてのキューが表示されます。
  5. キューの一覧から空にするキューを選択して、キュー名称をクリックしてキュー詳細ページに移動します。
  6. 再生リストの詳細ページ最下部にある「キューを空にする」ボタンを押すと、キューが空になります。

管理プラグインを使用しない場合は、プログラムによってキューを消去できます。たとえば、Pythonとpikaライブラリを使用してキューを消去するコードの例を以下に示します。

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_purge(queue='your_queue_name')
connection.close()

コード内の”your_queue_name”を空にしたいキューの名前に置き換えて実行するとキューが空になります。

注意として、キューをクリアしてしまうとキュー内のすべてのメッセージが削除されてしまうので、十分注意して操作してください。

bannerAds