Amazon SQS 可視性タイムアウト
コンシューマーがキューからメッセージを受信して処理しても、そのメッセージはキューに残ったままです。Amazon SQS では、メッセージが自動的に削除されません。Amazon SQS は分散システムであり、接続の問題やコンシューマーアプリケーションの問題などが原因で、コンシューマーが実際にメッセージを受信するという保証がないためです。そのため、コンシューマーはメッセージを受信して処理した後、キューからメッセージを削除する必要があります。
メッセージが受信された直後は、メッセージはキューに残ったままです。他のコンシューマーが同じメッセージを再び処理しないように、Amazon SQS は可視性タイムアウトを設定しています。この時間内では、他のコンシューマーによる同じメッセージの受信と処理が防止されます。メッセージのデフォルトの可視性タイムアウトは 30 秒です。最小値は
0 秒、最大スケールは 12 時間です。 AWS マネジメントコンソール を使用してキューに可視性タイムアウトを設定する方法、AWS SDK for Java (および
SetQueueAttributes、GetQueueAttributes、ReceiveMessage、ChangeMessageVisibility、ChangeMessageVisibilityBatch の各アクション) を使用して単一または複数のメッセージの可視性タイムアウトを設定する方法については、「キューに可視性タイムアウトを設定する」を参照してください。
注記
スタンダード キューの場合は、可視性タイムアウトはメッセージを 2 回受信しない保証にはなりません。詳細については、「少なくとも 1 回の配信」を参照してください。
FIFO キューでは、プロデューサーまたコンシューマーが複数の再試行を行うことができます。
-
コンシューマーが失敗した
SendMessageアクションを検出した場合、同じメッセージ重複排除 ID を使用して必要に応じて何回でも送信を再試行できます。重複排除の期間が終了する前にプロデューサーが少なくとも 1 つの確認を受信した場合、複数の再試行を行ってもメッセージの順序に影響したり、重複が発生したりすることはありません。 -
コンシューマーが失敗した
ReceiveMessageアクションを検出した場合、同じ受信リクエスト試行 ID を使用して必要に応じて何回でも再試行できます。可視性タイムアウトが終了する前にコンシューマーが少なくとも 1 つの確認を受信した場合、複数の再試行を行ってもメッセージの順序に影響はありません。 -
メッセージグループ ID を含むメッセージを受信した場合、メッセージを削除するか、メッセージが表示されるまで、同じメッセージグループ ID のメッセージはそれ以上返されません。
インフライトメッセージ
Amazon SQS メッセージには 3 つの基本的な状態があります。
-
プロデューサーによってキューへ送信される
-
コンシューマーによってキューから受信される
-
キューから削除される。
sent to a queue by a producer, but not yet received from the queue by a consumer の後 (つまり、状態 1 と 2 の中間)、メッセージは保存されているとみなされます。保存されるメッセージ数に制限はありません。received from a queue by a consumer, but not yet deleted from the queue の後は (つまり、状態 2 と 3 の中間)、メッセージはインフライトとみなされます。保存されるインフライトメッセージ数には制限があります。
重要
Limits that apply to inflight messages are unrelated to the unlimited number of stored messages.
ほとんどの スタンダード キューでは (キュートラフィックとメッセージバックログにより異なります)、最大 120,000 のインフライトメッセージが存在できます (received
from a queue by a consumer, but not yet deleted from the queue)。この制限に達した場合、Amazon
SQS は OverLimit エラーメッセージを返します。制限に到達しないようにするため、処理されたメッセージはキューから削除する必要があります。メッセージの処理に使用するキューの数を増やすこともできます。制限の引き上げをリクエストする場合は、サポートリクエストを提出してください。
FIFO キューの場合、キューには最大 20,000 のインフライトメッセージが存在できます (received from a queue by a consumer, but not yet deleted from the queue)。この制限に達した場合、Amazon SQS はエラーメッセージを返しません。
可視性タイムアウトの設定
可視性タイムアウトは Amazon SQS がメッセージを返した時点で始まります。タイムアウト時間内に、コンシューマーはメッセージを処理して削除します。ただし、コンシューマーでメッセージを削除する前に障害が発生して、DeleteMessage アクションが呼び出されないまま可視性タイムアウトの期限が切れると、そのメッセージは他のコンシューマーに見えるようになり、再度受信されます。メッセージを一度だけ受信する必要がある場合、コンシューマーは可視性タイムアウトの時間内にメッセージを削除する必要があります。
すべての Amazon SQS キューの可視性タイムアウトはデフォルトで 30 秒に設定されています。この設定はキュー全体で変更できます。通常、可視性タイムアウトは、アプリケーションがキューのメッセージを処理して削除するまでの最大所要時間に設定します。メッセージを受信したら、キュー全体のタイムアウトを変更しなくても、返されるメッセージに特別な可視性タイムアウトを設定することもできます。詳細については、「タイムリーな方法でのメッセージの処理」セクションのベストプラクティスを参照してください。
メッセージの処理にかかる時間がわからない場合は、コンシューマープロセスのハートビートを作成します。初期の可視性タイムアウト (たとえば 2 分) を指定し、(コンシューマーがメッセージを処理し続けている限り) 可視性タイムアウトの毎秒 2 分ずつ延長します。
メッセージの可視性タイムアウトの変更
キューからメッセージを受信し、処理を開始したときに、キューの可視性タイムアウトが十分でない場合があります (たとえば、メッセージを処理して削除する必要がある場合)。ChangeMessageVisibility アクションを使用して新しいタイムアウト値を指定すると、メッセージの可視性を短縮または拡張することができます。
たとえば、キューのデフォルトのタイムアウトが 60 秒であり、メッセージを受信してから 15 秒が経過したときに、VisibilityTimeout を 10 秒に設定した ChangeMessageVisibility コールを送信する場合、この 10 秒は ChangeMessageVisibility コールを行った時点からカウントが開始されます。したがって、最初に可視性タイムアウトを変更してから 10 秒 (合計 25 秒) 経過した後に可視性タイムアウトを変更しようとしたり、そのメッセージを削除しようとすると、エラーが発生する可能性があります。
注記
新しいタイムアウト期間は、ChangeMessageVisibility アクションを呼び出した時間から有効になります。さらに、新しいタイムアウト期間はメッセージの特定の受信にのみ適用されます。ChangeMessageVisibility は、メッセージの以降の受信や以降のキューには影響しません。
メッセージの可視性タイムアウトの終了
キューからメッセージを受信すると、そのメッセージを実際に処理して削除する必要がないことがわかる場合があります。Amazon SQS では、特定のメッセージの可視性タイムアウトを終了できます。その場合、システムの他のコンポーネントからメッセージがすぐに見えるようになり、処理できるようになります。
ReceiveMessage の呼び出し後、メッセージの可視性タイムアウトを終了するには、VisibilityTimeout を 0 秒に設定して、ChangeMessageVisibility を呼び出します。
