Amazon SQS の FIFO キュー配信ロジック

複数のメッセージが一意のメッセージ重複排除 ID とともに FIFO キューへ連続して送信されると、Amazon SQS はそれらを保存し、その送信を確認します。その後、これらのメッセージは、その送信順序どおりに正確に受信して処理されます。

FIFO キューでは、メッセージはメッセージグループ ID に基づいて順序付けられます。複数のプロデューサーまたはスレッドが同じメッセージグループ ID でメッセージを送信する場合、Amazon SQS はそれらが到着した順序で保存および処理されるようにします。

ベストプラクティス: 複数のプロデューサー間で厳密なメッセージ順序を保証するため、各プロデューサーからのすべてのメッセージに一意のメッセージグループ ID を割り当てます。

FIFO キューロジックはメッセージグループ ID ごとにのみ適用されます:

要件 - メッセージグループ ID を各メッセージに関連付ける必要があります。グループ ID なしでメッセージを送信すると、アクションは失敗します。

単一グループのシナリオ - すべてのメッセージを厳密な順序で処理する必要がある場合は、すべてのメッセージに同じメッセージグループ ID を使用します。

複数のメッセージグループ ID を持つ FIFO キューからメッセージを受信する場合、Amazon SQS は以下のように動作します。

重要な明確化

バッチで取得されたメッセージは、FIFO 順序をグループ内で保持します。

同じメッセージグループ ID で使用できるメッセージが 10 件未満の場合、Amazon SQS は同じバッチ内の他のメッセージグループ ID からのメッセージを含めることができますが、各グループは FIFO 順序を保持します。

特定のメッセージグループ ID からメッセージを受信するように明示的にリクエストすることはできません。

SendMessage アクションが失敗した場合、プロデューサーは同じメッセージ重複排除 ID を使用してメッセージの送信を複数回再試行できます。

重複排除間隔の期限が切れる前に、プロデューサーが少なくとも 1 つの確認を受け取る限り、再試行によって以下は発生しません。

ReceiveMessage アクションが失敗しても、コンシューマーは同じ受信リクエスト試行 ID を使用して、必要な回数だけ再試行できます。

可視性タイムアウトの期限が切れる前に、コンシューマーが少なくとも 1 つの確認を受け取る限り、再試行によって以下は発生しません。

メッセージは取得されても削除されていない場合、可視性タイムアウトの有効期限が切れるまで表示されません。

最初のメッセージが削除されるか、再び表示されるまで、同じメッセージグループ ID からの追加のメッセージは返されません。

FIFO キューでは、異なるメッセージグループ ID 間でメッセージを並列処理できます。

同時実行性を最大化するには、独立したワークフローに対複数のメッセージグループ ID を使ってシステムを設計します。

FIFO キュー内のすべてのメッセージを厳密に順序通り処理するには、キュー内のすべてのメッセージに対して単一のメッセージグループ ID を使用します。

プロデューサーが同じメッセージグループ ID グループ A を持つ 5 つのメッセージを送信します。

コンシューマーがこれらのメッセージを FIFO 順に受信します。コンシューマーがこれらのメッセージを削除するか、可視性タイムアウトの有効期限が切れるまで、グループ A から追加のメッセージは受信されません。

プロデューサーがグループ A に 5 つのメッセージを送信し、グループ B に 5 つのメッセージを送信します。

コンシューマー 1 がグループ A からのメッセージを処理し、コンシューマー 2 はグループ B からのメッセージを処理します。これにより、厳密に順序通りに各グループ内での並列処理が可能になります。

プロデューサーがグループ A に 7 つのメッセージを送信し、グループ B に 3 つのメッセージを送信します。

1 つのコンシューマーが最大 10 個のメッセージを取得します。キューが許可する場合、以下を返すことがあります。