Boto 3の勉強 その4 (SQS)

今日はこれ

まず、キューにメッセージを送信する。

import boto3

sqs = boto3.resource("sqs")

queue = sqs.get_queue_by_name(QueueName="test-queue-20220301")
response = queue.send_message(MessageBody="Test Message")

続いて、メッセージを取り出してプリントしてから、削除する。

get_message = queue.receive_messages()
for message in get_message:
    print(message.body)
    message.delete()

実行結果
キューにメッセージが残っている間は「Test Message」が表示される。
キューからメッセージが無くなると、何も表示されなくなる。

% python sample-sqs.py
Test Message

その後にマネコンをみると、「利用可能なメッセージ」が「0」になる。

SQS_デキュー