Amazon SQS でキューを作り、SNS との違いを体験する

前提条件

1. リージョン: ap-northeast-1（東京）
2. AWS マネジメントコンソールにログイン済みで、Amazon SQS と Amazon SNS を操作できる IAM 権限があること
3. 事前に作成しておくリソースはありません

作成するリソース一覧

標準キューを作成する

1. AWS マネジメントコンソールにログインし、リージョンが ap-northeast-1（東京）であることを確認します
2. 上部の検索バーに SQS と入力し、表示された「Simple Queue Service」を選択します
3. 「キューを作成」をクリックします
4. 「詳細」で以下を設定します
   • タイプ: 標準（デフォルト）
   • 名前: handson-orders-queue
5. 「設定」で以下を設定します
   • 可視性タイムアウト: 1 と入力し、右隣の単位を「分」にします（後の手順で「見えない時間」を確かめやすくするため、既定の 30 秒から延ばします）
   • その他の項目（メッセージ保持期間 4 日、配信遅延 0 秒、メッセージ受信待機時間 0 秒 など）はデフォルトのままにします
6. 「暗号化」「アクセスポリシー」「デッドレターキュー」などその他の項目はデフォルトのままにします（暗号化は、既定で Amazon SQS キー（SSE-SQS）によるサーバー側の暗号化が有効になっています。このままで、後の手順で SNS から届くメッセージも受け取れます）
7. ページ下部の「キューを作成」をクリックします

キューの詳細画面が表示され、「詳細」に URL と ARN が表示されていることを確認します。

メッセージを送信・受信・削除する

1. キューの詳細画面の右上で「メッセージを送受信」をクリックします
2. 「メッセージを送信」で、メッセージ本文に order-001: banana x 3 と入力します
3. 「メッセージを送信」をクリックします
4. 「メッセージを送信」セクションの上部に、「メッセージは送信済みであり、受信可能です。」と表示されます

1. 同じ画面の下部「メッセージを受信」で「メッセージをポーリング」をクリックします（「ポーリング期間」の既定値は 30 秒で、進行状況バーが 100% になるまでポーリングが続きます）
2. 「メッセージ」の一覧に、送信したメッセージ（ID と受信数 1）が表示されます
3. メッセージが表示されたら「ポーリングを停止」をクリックします。コンソールは、ポーリングを止める（または期間が終わる）と受信したメッセージを再び受信できる状態に戻します
4. メッセージ ID をクリックすると、「本文」タブで order-001: banana x 3 が確認できます。確認できたら「完了」をクリックして閉じます

1. 一覧で受信したメッセージのチェックボックスを選択し、一覧の右上の「削除」をクリックします
2. 「メッセージ を削除」ダイアログで「削除」をクリックします

メッセージは受信しただけではキューから消えず、コンシューマーが削除して初めて消えることが確認できます。

可視性タイムアウト中は見えないことを確認する

コンソールは、ポーリングを止める（または期間が終わる）と受信したメッセージを再び受信できる状態に戻します。そのため、「ポーリングを終えてから、すぐにもう一度ポーリングする」やり方では、可視性タイムアウトの動きを確かめられません。ここでは、ポーリング期間を可視性タイムアウトより長い 90 秒にして、1 回のポーリングの途中で受信数がどう変わるかを見ます。

1. 「メッセージを受信」の「ポーリング設定を編集」をクリックします
2. 「ポーリング期間」を 90（秒）に変更し、「保存」をクリックします（この設定はブラウザに保持され、画面を開き直しても残ります）
3. 「メッセージを送信」で、メッセージ本文に order-002: banana x 5 と入力し、「メッセージを送信」をクリックします
4. 「メッセージをポーリング」をクリックし、order-002 のメッセージが受信数 1 で表示されることを確認します（今回は「ポーリングを停止」も削除もせず、そのまま待ちます）
5. ポーリングを開始してから 30 秒ほどたった時点でも、受信数が 1 のままであること、「利用可能なメッセージ」が 0 であることを確認します。可視性タイムアウト（1 分）の間は、ポーリングを続けていても同じメッセージが再び届きません

1. さらに待ち、ポーリングを開始してから 1 分を少し過ぎたころに、order-002 の受信数が 2 に増えることを確認します
2. 確認できたら「ポーリングを停止」をクリックし、order-002 を選択して「削除」します

デッドレターキューを設定する

まず、デッドレターキューにする標準キューを作成します。

1. 左側ナビゲーションの「キュー」を選択し、「キューを作成」をクリックします
2. 以下を設定します
   • タイプ: 標準
   • 名前: handson-orders-dlq
   • メッセージ保持期間: 14 日（ソースキューの 4 日より長くします）
3. その他の項目はデフォルトのままにし、「キューを作成」をクリックします

次に、ソースキューにデッドレターキューを設定します。

1. 左側ナビゲーションの「キュー」から handson-orders-queue を選択し、右上の「編集」をクリックします
2. 「デッドレターキュー」セクションで「有効」を選択します
3. 以下を設定します
   • キューの選択: 「キュー ARN」のドロップダウンから handson-orders-dlq の ARN を選択
   • 最大受信数: 2（既定値は 10）
4. ページ下部の「保存」をクリックします

最大受信数を超えたメッセージが移ることを確認する

1. handson-orders-queue の詳細画面で「メッセージを送受信」をクリックします
2. メッセージ本文に order-003: broken order と入力し、「メッセージを送信」をクリックします
3. 「メッセージをポーリング」をクリックし、order-003 が受信数 1 で表示されることを確認したら、「ポーリングを停止」をクリックします（削除しません）
4. もう一度「メッセージをポーリング」をクリックし、受信数 2 で表示されることを確認したら、「ポーリングを停止」をクリックします（削除しません。コンソールはポーリングを止めると受信したメッセージを戻すので、1 分待つ必要はありません）
5. 3 回目として「メッセージをポーリング」をクリックし、order-003 が表示されないことを確認します（受信数が最大受信数 2 を超えるため、デッドレターキューに移されます）。確認できたら「ポーリングを停止」をクリックします

続いて、デッドレターキュー側を確認します。

1. 左側ナビゲーションの「キュー」を選択し、handson-orders-dlq の「利用可能なメッセージ」が 1 になっていることを確認します（件数の反映に少し時間がかかるときは、一覧の更新アイコンをクリックします）
2. handson-orders-dlq を選択して「メッセージを送受信」をクリックし、「メッセージをポーリング」をクリックします
3. 受信したメッセージの ID をクリックし、「本文」タブで order-003: broken order が確認できることを確認します（受信数は、元のキューでの 2 回にデッドレターキューでの 1 回を加えた 3 と表示されます）

SNS ファンアウト用のキューを 2 つ作成する

1. 左側ナビゲーションの「キュー」を選択し、「キューを作成」をクリックします
2. タイプ: 標準、名前: handson-shipping-queue を設定し、その他の項目はデフォルトのまま「キューを作成」をクリックします
3. 同じ手順で、名前 handson-billing-queue の標準キューを作成します
4. 作成した 2 つのキューの詳細画面で、それぞれの ARN（arn:aws:sqs:ap-northeast-1:<アカウントID>:handson-shipping-queue の形式）を控えておきます

SNS トピックを作成する

1. 上部の検索バーに SNS と入力し、表示された「Simple Notification Service」を選択します
2. 左側ナビゲーションの「トピック」を選択し、「トピックの作成」をクリックします
3. 以下を設定します
   • タイプ: スタンダード（既定では「FIFO」が選ばれているので、「スタンダード」に切り替えます）
   • 名前: handson-order-events
4. その他の項目はデフォルトのままにし、「トピックの作成」をクリックします
5. トピックの詳細画面に表示される ARN（arn:aws:sns:ap-northeast-1:<アカウントID>:handson-order-events の形式）を控えておきます

キューのアクセスポリシーで SNS からの送信を許可する

SNS トピックがキューにメッセージを送れるよう、2 つのキューのアクセスポリシーを編集します。

1. SQS コンソールに戻り、左側ナビゲーションの「キュー」から handson-shipping-queue を選択します
2. キューの詳細画面の「キューポリシー」タブ（既定で選ばれています）にある「アクセスポリシー」の「編集」をクリックします（画面右上の「編集」からも、同じ編集画面に進めます）
3. 編集画面の「アクセスポリシー」セクションの JSON エディタで、既存のステートメント（キューの所有者を許可するもの）は残したまま、"Statement" の配列に以下のステートメントを追加します。<アカウントID> は自分のアカウント ID に置き換えます

{
  "Sid": "AllowSNSOrderEvents",
  "Effect": "Allow",
  "Principal": {
    "Service": "sns.amazonaws.com"
  },
  "Action": "sqs:SendMessage",
  "Resource": "arn:aws:sqs:ap-northeast-1:<アカウントID>:handson-shipping-queue",
  "Condition": {
    "ArnEquals": {
      "aws:SourceArn": "arn:aws:sns:ap-northeast-1:<アカウントID>:handson-order-events"
    }
  }
}

1. ページ下部の「保存」をクリックします

1. handson-billing-queue についても同じ手順で編集します。Resource は arn:aws:sqs:ap-northeast-1:<アカウントID>:handson-billing-queue に置き換えます

2 つのキューをトピックにサブスクライブする

1. SNS コンソールの左側ナビゲーションで「トピック」を選択し、handson-order-events をクリックします
2. 「サブスクリプション」タブの「サブスクリプションの作成」をクリックします
3. 以下を設定します
   • トピック ARN: handson-order-events の ARN が自動で入っていることを確認
   • プロトコル: Amazon SQS
   • エンドポイント: 入力欄をクリックして一覧から handson-shipping-queue の ARN を選択（ARN を貼り付けてもかまいません）
4. その他の項目はデフォルトのままにし、「サブスクリプションの作成」をクリックします
5. サブスクリプションの詳細画面が開き、ステータスが「確認済み」と表示されます（同じアカウントの SQS キューは、確認の操作なしで自動的に確認済みになります）
6. トピックの詳細画面に戻り、同じ手順で、エンドポイントを handson-billing-queue の ARN にしたサブスクリプションを作成します
7. トピックの詳細画面の「サブスクリプション」タブに、2 つの SQS サブスクリプションが表示され、ステータスが「確認済み」になっていることを確認します

1 回の発行で 2 つのキューに届くことを確認する

1. トピック handson-order-events の詳細画面で「メッセージの発行」をクリックします
2. 以下を入力します
   • 件名: new-order
   • メッセージ本文（「メッセージ本文」セクションの「エンドポイントに送信するメッセージ本文」）: order-100: banana x 10
3. 「メッセージの発行」をクリックします
4. SQS コンソールに戻り、左側ナビゲーションの「キュー」を選択します
5. handson-shipping-queue と handson-billing-queue の「利用可能なメッセージ」が、どちらも 1 になっていることを確認します（件数の反映に少し時間がかかるときは、一覧の更新アイコンをクリックします）

1. handson-shipping-queue を選択して「メッセージを送受信」をクリックし、「メッセージをポーリング」をクリックします（メッセージが表示されたら「ポーリングを停止」をクリックします）
2. 表示されたメッセージの ID をクリックし、「本文」タブを確認します。SNS から届いたメッセージは JSON 形式で、"Type" : "Notification"、"TopicArn"、"Subject" : "new-order"、"Message" : "order-100: banana x 10" などが含まれていることが確認できます

1. handson-billing-queue でも同様にポーリングし、同じ内容のメッセージが届いていることを確認します

1 回の発行で 2 つのキューに同じメッセージが届き、それぞれのキューから別々に受信できることが確認できます。