<h2 id="%E5%88%9D%E3%82%81%E3%81%AB" data-line="0" class="code-line">
<a class="header-anchor-link" href="#%E5%88%9D%E3%82%81%E3%81%AB" aria-hidden="true"></a> 初めに</h2>
<p data-line="2" class="code-line">今回は、Amazon SNSとAmazon SQSのファンアウトイベント通知について試してみたいと思います。</p>
<p data-line="4" class="code-line"><br><br></p>
<h2 id="%E3%83%95%E3%82%A1%E3%83%B3%E3%82%A2%E3%82%A6%E3%83%88%EF%BC%88fan-out%EF%BC%89%E3%82%A4%E3%83%99%E3%83%B3%E3%83%88%E9%80%9A%E7%9F%A5%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6" data-line="6" class="code-line">
<a class="header-anchor-link" href="#%E3%83%95%E3%82%A1%E3%83%B3%E3%82%A2%E3%82%A6%E3%83%88%EF%BC%88fan-out%EF%BC%89%E3%82%A4%E3%83%99%E3%83%B3%E3%83%88%E9%80%9A%E7%9F%A5%E3%81%AB%E3%81%A4%E3%81%84%E3%81%A6" aria-hidden="true"></a> ファンアウト（Fan-out）イベント通知について</h2>
<p data-line="8" class="code-line">ファンアウトイベント通知とは、1つのイベント（通知）を複数のシステム（またはサービス）に並列/非同期処理通知する設計パターンのことを指します。<br>
その方法の一つとして、Amazon SNS (Simple Notification Service)とAmazon SQS (Simple Queue Service)を連携させることで実現することができます。例えば、ECサイトでの新しい注文のイベントが発生した際に、1つの注文完了のイベントをSNSで送信し、複数の宛先（在庫管理用SQSキュー、ユーザー通知用Lambda関数、HTTPエンドポイント）に一斉に通知することができます。イベントを処理するAmazon SQSとは別に、ログ専用のAmazon SQSやAmazon S3にも通知が可能です。</p>
<div class="code-block-container"><pre class="language-bash"><code class="language-bash code-line" data-line="12">          <span class="token punctuation">[</span>イベント発生<span class="token punctuation">]</span>
                │
                ▼
           <span class="token punctuation">[</span>SNSトピック<span class="token punctuation">]</span> ← プロデューサー
         ┌───────┬───────┐
         ▼       ▼ 　　　 ▼
       <span class="token punctuation">[</span>SQS<span class="token punctuation">]</span>  <span class="token punctuation">[</span>Lambda<span class="token punctuation">]</span> <span class="token punctuation">[</span>HTTP<span class="token punctuation">]</span> ← コンシューマ
</code></pre></div><p data-line="23" class="code-line"><br><br></p>
<h2 id="amazon-sqs%E3%81%A8%E3%81%AF" data-line="25" class="code-line">
<a class="header-anchor-link" href="#amazon-sqs%E3%81%A8%E3%81%AF" aria-hidden="true"></a> Amazon SQSとは</h2>
<p data-line="27" class="code-line">Amazon SQS（Simple Queue Service）は、異なるシステム間で非同期にメッセージを仲介するための、フルマネージドなキューイングサービスです。ソフトウェア間を直接データを渡すのではなく、キュー経由でデータを渡すことで、任意のタイミングで好きな処理を行うことができます。サーバーの管理が不要でAWSがフルマネージドで提供しており、初期投資不要（従量課金）となっています。<br>
また、Amazon SQSの大きなメリットの一つとして、大量のリクエストが一時的に発生した場合にキューで受け取りバッファリングし、処理側にとって均一な負荷で処理できるようにすることがあります。例えば、一時的に注文・リクエストが殺到するWebアプリにおいて、受信側が処理できるスピード（バックエンドのEC2が可能な範囲）に合わせて、非同期に処理を流すことが可能です。</p>
<p data-line="30" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__5b36256745fbf" src="https://embed.zenn.studio/card#zenn-embedded__5b36256745fbf" data-content="https%3A%2F%2Fdocs.aws.amazon.com%2Fsns%2Flatest%2Fdg%2Fwelcome.html" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://docs.aws.amazon.com/sns/latest/dg/welcome.html" style="display:none" target="_blank" rel="nofollow noopener noreferrer">https://docs.aws.amazon.com/sns/latest/dg/welcome.html</a></p>
<p data-line="32" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__d4da6d4ee4ce" src="https://embed.zenn.studio/card#zenn-embedded__d4da6d4ee4ce" data-content="https%3A%2F%2Fdocs.aws.amazon.com%2FAWSSimpleQueueService%2Flatest%2FSQSDeveloperGuide%2Fwelcome.html" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html" style="display:none" target="_blank" rel="nofollow noopener noreferrer">https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html</a></p>
<p data-line="34" class="code-line"><br><br></p>
<h2 id="%E3%81%AA%E3%81%9Camazon-sqs%E3%81%8C%E5%BF%85%E8%A6%81%E3%81%AA%E3%81%AE%E3%81%8B%EF%BC%9F" data-line="36" class="code-line">
<a class="header-anchor-link" href="#%E3%81%AA%E3%81%9Camazon-sqs%E3%81%8C%E5%BF%85%E8%A6%81%E3%81%AA%E3%81%AE%E3%81%8B%EF%BC%9F" aria-hidden="true"></a> なぜAmazon SQSが必要なのか？</h2>
<p data-line="38" class="code-line">Amazon SNSは通知を「送る」ためのサービスであり、パブリシャーの役割をはたします。一方でAmazon SQSはメッセージを「受け取って、ためておく」ためのサービスです。Amazon SNSは即時通知が得意ですが、通知先で処理が失敗した場合や一時的に処理できない場合には弱いため、Amazon SQSはキューにためて後で確実に処理するのでシステムの一時停止や高負荷で処理が追いつかない場合でも、メッセージが失われてしまうことを防ぐことができます。</p>
<p data-line="40" class="code-line"><br><br></p>
<h2 id="%E6%A7%8B%E7%AF%89%E6%89%8B%E9%A0%86%EF%BC%88%E3%83%9E%E3%83%8D%E3%82%B8%E3%83%A1%E3%83%B3%E3%83%88%E3%82%B3%E3%83%B3%E3%82%BD%E3%83%BC%E3%83%AB%EF%BC%89" data-line="42" class="code-line">
<a class="header-anchor-link" href="#%E6%A7%8B%E7%AF%89%E6%89%8B%E9%A0%86%EF%BC%88%E3%83%9E%E3%83%8D%E3%82%B8%E3%83%A1%E3%83%B3%E3%83%88%E3%82%B3%E3%83%B3%E3%82%BD%E3%83%BC%E3%83%AB%EF%BC%89" aria-hidden="true"></a> 構築手順（マネジメントコンソール）</h2>
<p data-line="44" class="code-line">それでは構築手順に進みます。流れは大きく分けて4つのステップで構成されます。</p>
<p data-line="46" class="code-line">① SNSトピックの作成<br>
② SQSキューの作成（2つ）<br>
③ SNSトピックにSQSキューを購読させる（サブスクライブ）<br>
④ 動作確認（SNSトピックにメッセージを送信）</p>
<p data-line="51" class="code-line"><br><br></p>
<h3 id="sns%E3%83%88%E3%83%94%E3%83%83%E3%82%AF%E3%81%AE%E4%BD%9C%E6%88%90" data-line="53" class="code-line">
<a class="header-anchor-link" href="#sns%E3%83%88%E3%83%94%E3%83%83%E3%82%AF%E3%81%AE%E4%BD%9C%E6%88%90" aria-hidden="true"></a> SNSトピックの作成</h3>
<p data-line="55" class="code-line">Amazon SNSから「SNSトピックを作成」の項目に移動します。<br>
トピック名を入力後、「次のステップ」ボタンをクリックします。</p>
<p data-line="58" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/85984521d05e-20250512.png" loading="lazy" class="md-img"></p>
<p data-line="60" class="code-line"><br></p>
<p data-line="62" class="code-line">スタンダードを選択して、その他はデフォルトでOKです。</p>
<p data-line="64" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/4199e44a2fd6-20250512.png" loading="lazy" class="md-img"></p>
<p data-line="66" class="code-line">「トピックの作成」ボタンをクリックしたらSNSトピックの作成が完了です。</p>
<p data-line="68" class="code-line"><br><br></p>
<h3 id="sqs%E3%82%AD%E3%83%A5%E3%83%BC%E3%81%AE%E4%BD%9C%E6%88%90" data-line="70" class="code-line">
<a class="header-anchor-link" href="#sqs%E3%82%AD%E3%83%A5%E3%83%BC%E3%81%AE%E4%BD%9C%E6%88%90" aria-hidden="true"></a> SQSキューの作成</h3>
<p data-line="72" class="code-line">Amazon SQSに移動して、SNSトピックをサブスクライブするSQSキューを作成します。</p>
<p data-line="74" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/a719534eea57-20250512.png" loading="lazy" class="md-img"></p>
<p data-line="76" class="code-line"><br></p>
<p data-line="78" class="code-line">Amazon SNSと同様にスタンダードを選択して、その他はデフォルトのまま「キューの作成」ボタンをクリックします。</p>
<p data-line="80" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/2d4c43aef662-20250512.png" loading="lazy" class="md-img"></p>
<p data-line="82" class="code-line">同様の手順で2つ目のSQSキューも作成しておきます。</p>
<p data-line="85" class="code-line"><br><br></p>
<h3 id="sns%E3%83%88%E3%83%94%E3%83%83%E3%82%AF%E3%81%ABsqs%E3%82%AD%E3%83%A5%E3%83%BC%E3%82%92%E8%B3%BC%E8%AA%AD%E3%81%95%E3%81%9B%E3%82%8B" data-line="87" class="code-line">
<a class="header-anchor-link" href="#sns%E3%83%88%E3%83%94%E3%83%83%E3%82%AF%E3%81%ABsqs%E3%82%AD%E3%83%A5%E3%83%BC%E3%82%92%E8%B3%BC%E8%AA%AD%E3%81%95%E3%81%9B%E3%82%8B" aria-hidden="true"></a> SNSトピックにSQSキューを購読させる</h3>
<p data-line="89" class="code-line">Amazon SNSに再度移動し作成したトピックを開き、「サブスクリプションの作成」をクリックします。プロトコルにAmazon SQSを設定、エンドポイントに先ほど作成したSQSキューを指定して作成します。</p>
<p data-line="91" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/9f97f376f36b-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="93" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/0acb6bb8f378-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="95" class="code-line">同様の手順で2つ目のキューにもサブスクリプションを指定します。</p>
<p data-line="97" class="code-line"><br><br></p>
<h3 id="%E5%8B%95%E4%BD%9C%E7%A2%BA%E8%AA%8D" data-line="99" class="code-line">
<a class="header-anchor-link" href="#%E5%8B%95%E4%BD%9C%E7%A2%BA%E8%AA%8D" aria-hidden="true"></a> 動作確認</h3>
<p data-line="101" class="code-line">それではAmazon SNSのトピックからメッセージを発行してみます。</p>
<p data-line="103" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/86798baf9fca-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="105" class="code-line"><br></p>
<p data-line="107" class="code-line">発行ボタンをクリックした後、件名とメッセージ（例えば<code>{"event":"new_order","order_id":"12345"}</code>）を入力して発行ボタンをクリックします。</p>
<p data-line="109" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/181b9348bbe7-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="111" class="code-line">これでAmazon SNSから、トピックをサブスクライブしているすべてのエンドポイントにメッセージが発行されます。</p>
<p data-line="113" class="code-line"><br></p>
<p data-line="115" class="code-line">Amazon SQSに移動して、「メッセージを送受信」のボタンをクリックします。</p>
<p data-line="117" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/da124fb2751d-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="119" class="code-line">ポーリングして、メッセージを受信し内容を表示します。</p>
<p data-line="121" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/1f6b5527df0a-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="123" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/6a27e1353f1e-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="125" class="code-line">このままだと再受信してしまうため、受け取ったメッセージは削除しておきます。</p>
<p data-line="127" class="code-line"><img src="https://storage.googleapis.com/zenn-user-upload/9ff4d0baab68-20250514.png" loading="lazy" class="md-img"></p>
<p data-line="129" class="code-line"><br><br></p>
<h2 id="%E6%9C%80%E5%BE%8C%E3%81%AB" data-line="131" class="code-line">
<a class="header-anchor-link" href="#%E6%9C%80%E5%BE%8C%E3%81%AB" aria-hidden="true"></a> 最後に</h2>
<p data-line="133" class="code-line">ファンアウトイベント通知について試してみましたが、割と簡単に設定できることがわかりました。ここまで読んでいただきありがとうございました。</p>
<p data-line="136" class="code-line"><br><br></p>
<h2 id="%E5%8F%82%E8%80%83%E8%B3%87%E6%96%99" data-line="138" class="code-line">
<a class="header-anchor-link" href="#%E5%8F%82%E8%80%83%E8%B3%87%E6%96%99" aria-hidden="true"></a> 参考資料</h2>
<p data-line="140" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__81b2a21cbd5be" src="https://embed.zenn.studio/card#zenn-embedded__81b2a21cbd5be" data-content="https%3A%2F%2Faws.amazon.com%2Fjp%2Fgetting-started%2Fhands-on%2Fsend-fanout-event-notifications%2F" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://aws.amazon.com/jp/getting-started/hands-on/send-fanout-event-notifications/" style="display:none" target="_blank" rel="nofollow noopener noreferrer">https://aws.amazon.com/jp/getting-started/hands-on/send-fanout-event-notifications/</a></p>
<p data-line="142" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__2608cae6c05e4" src="https://embed.zenn.studio/card#zenn-embedded__2608cae6c05e4" data-content="https%3A%2F%2Fdev.classmethod.jp%2Farticles%2Faws-sns-sqs-fanout%2F" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://dev.classmethod.jp/articles/aws-sns-sqs-fanout/" style="display:none" target="_blank" rel="nofollow noopener noreferrer">https://dev.classmethod.jp/articles/aws-sns-sqs-fanout/</a></p>
<p data-line="144" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__29a62b1c38206" src="https://embed.zenn.studio/card#zenn-embedded__29a62b1c38206" data-content="https%3A%2F%2Fzenn.dev%2Fmn87%2Farticles%2F57fd79e985ca19" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://zenn.dev/mn87/articles/57fd79e985ca19" style="display:none" target="_blank">https://zenn.dev/mn87/articles/57fd79e985ca19</a></p>
<p data-line="146" class="code-line"><span class="embed-block zenn-embedded zenn-embedded-card"><iframe id="zenn-embedded__d8ee55ae81671" src="https://embed.zenn.studio/card#zenn-embedded__d8ee55ae81671" data-content="https%3A%2F%2Fwww.slideshare.net%2Fslideshow%2F20190717-aws-black-belt-online-seminar-amazon-simple-queue-service%2F156346120" frameborder="0" scrolling="no" loading="lazy"></iframe></span><a href="https://www.slideshare.net/slideshow/20190717-aws-black-belt-online-seminar-amazon-simple-queue-service/156346120" style="display:none" target="_blank" rel="nofollow noopener noreferrer">https://www.slideshare.net/slideshow/20190717-aws-black-belt-online-seminar-amazon-simple-queue-service/156346120</a></p>
<p data-line="148" class="code-line"><br></p>


Amazon  SNSとSQSでファンアウトイベント（Fan-out）通知を試してみる

ファンアウト（Fan-out）イベント通知について

SNSトピックにSQSキューを購読させる

構築手順（マネジメントコンソール）

Discussion