✨

【初心者向け】Amazon Simple Queue Service (SQS) 入門！完全ガイド

2023/07/03に公開

AWS

study

tech

Amazon Simple Queue Service (SQS)

☘️ はじめに

本ページは、AWS に関する個人の勉強および勉強会で使用することを目的に、AWS ドキュメントなどを参照し作成しておりますが、記載の誤り等が含まれる場合がございます。

最新の情報については、AWS 公式ドキュメントをご参照ください。

👀 Contents

SQS とは
SQS 構成要素
キュータイプ
メッセージグループ ID
メッセージ重複排除
可視性タイムアウト
配信遅延（遅延キュー）
- メッセージタイマー
メッセージ受信待機時間
- ショートポーリングとロングポーリング
メッセージ保持期間
最大メッセージサイズ
デッドレターキュー
暗号化
📖 まとめ

SQS とは

Duration: 0:58:54

フルマネージドのキューイングサービスです。

【AWS Black Belt Online Seminar】Amazon Simple Queue Service(YouTube)(58:54)

sqs

SQS 構成要素

Duration: 0:01:00

プロデューサー（Producer）
- メッセージを SQS に送信するアプリケーション
コンシューマー（Consumer）
- SQS からメッセージを取り出すアプリケーション
- Pull 型（コンシューマー側から一定間隔でデータ有無を確認する）
メッセージ（Message）
- 送受信されるデータ
キュー（Queue）
- メッセージをためておく場所

sqs-queue

キュータイプ

Duration: 0:01:00

標準キュー
FIFO キュー

違いは、アプリケーション間連携を疎結合で実現。「Amazon SQS」をグラレコで解説の図が分かりやすいです。

sns-queuetype

メッセージグループ ID

Duration: 0:01:00

メッセージグループ ID の使用

メッセージ送信時に MessageGroupId を指定することで、メッセージをグループ化できます。

FIFO キューでは、グループ単位で順序が保証されますが、異なるグループ間では順序は守られません。

aws sqs send-message \
    --queue-url ${QUEUE_URL} \
    --message-body '{"message": "test"}' \
    --message-group-id Group1 \

メッセージ重複排除

Duration: 0:01:00

メッセージ重複排除 ID の使用

FIFO キューで指定することで、5分間 は同一の重複排除 ID
ID のメッセージが受け付けられないようになるという機能です。

aws sqs send-message \
    --queue-url ${QUEUE_URL} \
    --message-body '{"message": "test"}' \
    --message-group-id Group1 \
    --message-deduplication-id "Deduplication${i}"

キューの属性で、コンテンツに基づく重複排除 のオプションを ON にした場合は、重複排除 ID の事前指定は不要になります。

sqs-duplicate-contents

可視性タイムアウト

Duration: 0:01:00

可視性タイムアウト

sqs-visibilitytimeout

SQS ではメッセージを取得しても自動で削除されることはありません。コンシューマー側が処理済みとして削除するか、メッセージの保持期間が過ぎて削除されるかです。
複数のコンシューマーがメッセージを読み取った場合、重複して処理されてしまう可能性があるため、可視性タイムアウトという処理中のメッセージが他のコンシューマーからは取得できなくする機能があります。0 秒から 12 時間が指定できます。デフォルト値は 30 秒です。
コンシューマーは、可視性タイムアウトの時間に取得したメッセージを削除する必要があります。可視性タイムアウトの時間が過ぎると、メッセージを削除できなくなり、他のコンシューマーが取得できる状態になります。

メッセージの処理時間が不明な場合、可視性タイムアウトを 1 分毎に 2 分間延長することもできます。
タイムリーな方法でのメッセージの処理
 メッセージの可視性タイムアウトの変更

標準キューの場合は、メッセージの順序保証がないキューのため、他のコンシューマーがアクセスした場合、次のキューを取り出すことができます。
FIFO キューの場合は、メッセージの順序が重要であるため、可視性タイムアウト時間が過ぎるか、メッセージが削除されるまで、次のキューを取得することが出来ません。ただし、他のメッセージグループからはメッセージを取得することが出来ます。

配信遅延（遅延キュー）

Duration: 0:01:30

遅延キュー

プロデューサー側からキューに新しいメッセージが送信された後に、指定した時間が経過してからコンシューマー側にメッセージが表示されるようにする設定です。0 秒から 15 分までの間を指定できます。

sqs-delay

メッセージタイマー

キュー全体に指定する遅延キュー以外に、メッセージ個別に設定できるメッセージタイマーという機能があります。遅延キューと同時に指定された場合、メッセージに設定されたメッセージタイマーのほうが優先されます。0 秒から 15 分までの間を指定できます。

aws sqs send-message \
    --queue-url ${QUEUE_URL} \
    --message-body '{"message": "test"}' \
    --delay-seconds 900

メッセージ受信待機時間

Duration: 0:01:30

メッセージ取得までの待機時間です。0 秒から 20 秒まで指定することができます。0 秒を指定すると、ショートポーリングになります。

sqs-waitseconts

ショートポーリングとロングポーリング

ロングポーリング
- 通常はこちらを利用する。単一のキューをポーリングする多くのケースで有効。
- メッセージが空だった場合、最大 20 秒の間待機してメッセージの受領を待つ。それでも空だった場合に「空」応答を返す。
- ショートポーリングに比べて API コール数が減る（コストダウン）
ショートポーリング
- メッセージがなかったら、即座に「空」応答を返す。
- 主に、複数のキューをポーリングする場合に即時空応答が返ってくるほうが良い場合に。
- ロングポーリングに比べて API コール数が増える（コストアップ）