RabbitMQ の一時停止されたキュー同期の解決

Amazon MQ コンソールにサインインします。

左側のナビゲーションペインで [Brokers] (ブローカー) をクリックします。

ブローカーのリストから、新しいポリシーを適用するブローカーの名前を選択します。

ブローカーのページの [Connections] (接続) セクションで、RabbitMQ ウェブコンソール URL をメモします。新しいブラウザタブまたはウィンドウに RabbitMQ ウェブコンソールが開きます。

ブローカー管理者のサインイン認証情報を使用して RabbitMQ ウェブコンソールにログインします。

RabbitMQ ウェブコンソールのページ上部で、[Admin] (管理) をクリックします。

[Admin] (管理) ページの右側にあるナビゲーションペインで [Policies] (ポリシー) をクリックします。

[Policies] (ポリシー) ページに、ブローカーの現在の [User policies] (ユーザーポリシー) が表示されます。[User policies] (ユーザーポリシー) の下で、[Add / update a policy] (ポリシーの追加/更新) を展開します。

新しいブローカーポリシーを作成するには、[Add / update a policy] (ポリシーの追加/更新) で以下を実行します。

1. [Name] (名前) には、ポリシーの名前 (batch-size-policy など) を入力します。

2. [Pattern] (パターン) には regexp パターン .* を入力して、ポリシーがブローカー上のすべてのキューと一致するようにします。

3. [Apply to] (適用先) には、ドロップダウンリストから [Exchanges and queues] (エクスチェンジとキュー) を選択します。

4. [Priority] (優先順位) には、vhost に適用されたその他すべてのポリシーよりも大きい整数を入力します。RabbitMQ のキューとエクスチェンジに適用できるのは、常に 1 つのポリシー定義セットのみです。RabbitMQ は、一致するポリシーで、最高の優先順位値を持つものを選択します。ポリシーの優先順位とポリシーの結合方法の詳細については、RabbitMQ サーバードキュメントの「Policies」を参照してください。

5. [Definition] (定義) には、以下のキーバリューペアを追加します。

   • ha-sync-batch-size=100。ドロップダウンリストから [Number] (数値) を選択します。

     注記

     ha-sync-batch-size の値は、キュー内の同期されていないメッセージの数とサイズに基づいて調整と較正を行う必要がある場合があります。

   • ha-mode=all。ドロップダウンリストから [String] (文字列) を選択します。

     重要

     ha-mode 定義は、すべての HA 関連ポリシーに必須です。省略すると、検証が失敗します。

   • ha-sync-mode=automatic。ドロップダウンリストから [String] (文字列) を選択します。

     注記

     ha-sync-mode 定義は、すべてのカスタムポリシーに必須です。省略すると、Amazon MQ が定義を自動的に付加します。

6. [Add / update policy] (ポリシーを追加/更新) をクリックします。

[User policies] (ユーザーポリシー) リストに新しいポリシーが表示されることを確認します。

Amazon MQ コンソールにサインインします。

左側のナビゲーションペインで [Brokers] (ブローカー) をクリックします。

ブローカーのリストから、新しいポリシーを適用するブローカーの名前を選択します。

ブローカーのページの [Connections] (接続) セクションで、RabbitMQ ウェブコンソール URL をメモします。これは、HTTP リクエストで使用するブローカーエンドポイントです。

任意の新しいターミナルまたはコマンドラインウィンドウを開きます。

新しいブローカーポリシーを作成するには、以下の curl コマンドを入力します。このコマンドでは、%2F としてエンコードされているデフォルト / vhost 上のキューを前提としています。

curl -i -u username:password -H "content-type:application/json" -XPUT \
-d '{"pattern":".*", "priority":1, "definition":{"ha-sync-batch-size":100, "ha-mode":"all", "ha-sync-mode":"automatic"}}' \
https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies/%2F/batch-size-policy
                

新しいポリシーがブローカーのユーザーポリシーに追加されていることを確認するには、以下の curl コマンドを入力して、すべてのブローカーポリシーをリストします。

curl -i -u username:password https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies

RabbitMQ ウェブコンソールのページ上部で、[Queues] (キュー) をクリックします。

[Queues] (キュー) ページの [All queues] (すべてのキュー) で、一時停止されたキューを見つけます。キューが、[Features] (特徴) 列に作成された新しいポリシーの名前をリストします (batch-size-policy など)。

縮小されたバッチサイズで同期プロセスを再開するには、[Restart sync] (同期を再開) をクリックします。