AWS SQSとSNSで疎結合アーキテクチャを設計する方法｜キューイングとファンアウトの使い分け

この記事のポイント

・SQSは1対1のキューイング、SNSは1対多のファンアウト配信
・SNS+SQSの組み合わせでメッセージの蓄積とファンアウトを両立できる
・VPCエンドポイントでSQS/SNS通信をAWSネットワーク内に閉じセキュリティを強化する
・FIFOトピックとFIFOキューは必ずセットで使う（混在不可）

# SQSへのメッセージ送信（プロデューサー側）
aws sqs send-message     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/MyQueue     --message-body "注文ID:20260717-001の処理依頼"

# メッセージ受信（コンシューマー側）
aws sqs receive-message     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/MyQueue
# 出力例:
# {
#     "Messages": [{
#         "MessageId": "abc123-def456",
#         "Body": "注文ID:20260717-001の処理依頼",
#         "ReceiptHandle": "AQEBxxx..."
#     }]
# }

# SNSトピックへのパブリッシュ
aws sns publish     --topic-arn arn:aws:sns:ap-northeast-1:123456789012:OrderEvents     --message "注文ID:20260717-001の決済完了"

# 出力例:
# {
#     "MessageId": "xyz789-abcd-efgh-ijkl-012345678901"
# }
# 購読しているSQS・Lambda・メール全てに即時配信される

# デッドレターキューの設定（RedrivePolicy）
aws sqs set-queue-attributes     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/MainQueue     --attributes '{
        "RedrivePolicy": "{\"deadLetterTargetArn\":\"arn:aws:sqs:ap-northeast-1:123456789012:DLQueue\",\"maxReceiveCount\":\"3\"}"
    }'
# maxReceiveCount=3 : 3回処理失敗でDLQへ移動

# DLQのメッセージ数を確認
aws sqs get-queue-attributes     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/DLQueue     --attribute-names ApproximateNumberOfMessages
# 出力例:
# {"Attributes": {"ApproximateNumberOfMessages": "2"}}
# 0以外ならCloudWatchアラームで通知する運用が鉄則

# ファンアウトキューイングパターン 構成イメージ
#
# [プロデューサー（注文サービス）]
#              |
#              v
#   [SNSトピック: OrderEvents]
#       |            |            |
#       v            v            v
# [SQS:在庫]    [SQS:決済]    [SQS:メール]
#       |            |            |
#       v            v            v
# [在庫Worker]  [決済Worker]  [メールWorker]

# 1. SNSトピックの作成
aws sns create-topic --name OrderEvents
# 出力例: {"TopicArn": "arn:aws:sns:ap-northeast-1:123456789012:OrderEvents"}

# 2. SQSキューの作成（在庫管理用）
aws sqs create-queue --queue-name InventoryQueue
# 出力例: {"QueueUrl": "https://sqs.ap-northeast-1.amazonaws.com/123456789012/InventoryQueue"}

# 3. SQSキューにSNSからの送信を許可するポリシーを設定（必須）
# 注意: このポリシーがないとSNSからのメッセージがサイレントに失敗する
aws sqs set-queue-attributes     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/InventoryQueue     --attributes '{"Policy": "{\"Version\":\"2012-10-17\",\"Statement\":[{\"Effect\":\"Allow\",\"Principal\":{\"Service\":\"sns.amazonaws.com\"},\"Action\":\"sqs:SendMessage\",\"Resource\":\"arn:aws:sqs:ap-northeast-1:123456789012:InventoryQueue\",\"Condition\":{\"ArnEquals\":{\"aws:SourceArn\":\"arn:aws:sns:ap-northeast-1:123456789012:OrderEvents\"}}}]}"}'

# 4. SNSトピックにSQSをサブスクライブ
aws sns subscribe     --topic-arn arn:aws:sns:ap-northeast-1:123456789012:OrderEvents     --protocol sqs     --notification-endpoint arn:aws:sqs:ap-northeast-1:123456789012:InventoryQueue
# 出力例: {"SubscriptionArn": "arn:aws:sns:ap-northeast-1:123456789012:OrderEvents:xxxxxxxx"}

# 5. テストパブリッシュ
aws sns publish     --topic-arn arn:aws:sns:ap-northeast-1:123456789012:OrderEvents     --message "注文完了イベント 注文ID=20260717-001"

# 6. SQSキューで受信確認
aws sqs receive-message     --queue-url https://sqs.ap-northeast-1.amazonaws.com/123456789012/InventoryQueue
# メッセージが届いていれば設定成功

# SQS用VPCエンドポイントの作成（インターフェイス型）
aws ec2 create-vpc-endpoint     --vpc-id vpc-0a1b2c3d4e5f67890     --vpc-endpoint-type Interface     --service-name com.amazonaws.ap-northeast-1.sqs     --subnet-ids subnet-0a1b2c3d subnet-0e5f6a7b     --security-group-ids sg-0a1b2c3d4e5f67890
# 出力例: {"VpcEndpoint": {"VpcEndpointId": "vpce-0a1b2c3d4e5f67890", "State": "pending"}}

# SNS用VPCエンドポイントの作成
aws ec2 create-vpc-endpoint     --vpc-id vpc-0a1b2c3d4e5f67890     --vpc-endpoint-type Interface     --service-name com.amazonaws.ap-northeast-1.sns     --subnet-ids subnet-0a1b2c3d subnet-0e5f6a7b     --security-group-ids sg-0a1b2c3d4e5f67890

# エンドポイントの状態確認（available になれば使用可能）
aws ec2 describe-vpc-endpoints     --filters "Name=vpc-id,Values=vpc-0a1b2c3d4e5f67890"     --query "VpcEndpoints[*].{ID:VpcEndpointId,Service:ServiceName,State:State}"
# 出力例:
# [
#     {"ID": "vpce-0a1b2c3d", "Service": "com.amazonaws.ap-northeast-1.sqs",  "State": "available"},
#     {"ID": "vpce-1e2f3g4h", "Service": "com.amazonaws.ap-northeast-1.sns",  "State": "available"}
# ]

# セキュリティグループのインバウンドルール確認
aws ec2 describe-security-groups     --group-ids sg-0a1b2c3d4e5f67890     --query "SecurityGroups[*].IpPermissions"
# ポート443(HTTPS)のインバウンドがEC2/Lambdaのセキュリティグループから許可されているか確認

# エンドポイントのDNS名を確認（プライベートDNS有効化が必要な場合がある）
aws ec2 describe-vpc-endpoints     --filters "Name=vpc-id,Values=vpc-0a1b2c3d4e5f67890"     --query "VpcEndpoints[*].DnsEntries"