はじめに

Amazon SQSの標準キューの順序について、公式の説明では以下のように記載されています。

スタンダードキューでは、できる限りメッセージの順序を保持しますが、複数のメッセージのコピーが順不同で配信される場合があります。

この”できる限り”が気になってみたので動きを見てみました。

得られた知見

最初は、順序の初めのほうがとられやすい傾向がある
何度も（今回は３度）取得されると、しばらく取得されなくなり、別のメッセージが取得されるようになる
- しばらくたつと、また取得されるようになる

やったこと

検証設定と予想

設定
- 標準キュー
  - 可視性タイムアウトは３秒
- １秒ずつ、１つのメッセージを取得
予想
- 標準キューの順序の保持が強ければ強いほど、最初のメッセージばかり取得される
  - 仮に最も強く順序が保持されるならば、（可視性タイムアウトが３秒なので）最初の３つのメッセージのみ取得される、はず

検証準備

SQS作成

標準キューの可視性タイムアウトが３秒であれば、あとは簡易な構成で作成しました。何度も再取得するので、デッドレターキューは設定しないです。

メッセージ登録

0から99までの数値をメッセージとして登録します。以下のコマンドはCloudShellのpython3で実行しました。(0.5秒のスリープは気持ちの問題です)

メッセージ登録

import boto3
import time

sqs = boto3.resource('sqs')
queue = sqs.get_queue_by_name(QueueName='test20230130-standard')

for num in range(100):
  print(num)
  queue.send_message( MessageBody=str(num) )
  time.sleep(0.5)

メッセージ取得

１秒ごとにメッセージを1つ取得するのを1000回繰り返し、ファイルに出力しています。実行中がわかるように標準出力にも出しています。

メッセージ取得

import boto3
import time

sqs = boto3.resource('sqs')
queue = sqs.get_queue_by_name(QueueName='test20230130-standard')

with open('outs.txt', 'w') as f:
  for num in range(1000):
    for eachMsg in queue.receive_messages(MaxNumberOfMessages=1):
      print(eachMsg.body)
      f.write("%s\n"%(eachMsg.body) )
    print("-----")
    time.sleep(1)