【SQS】【Python】メッセージを送信(JSONリスト)

コードmemo

import boto3
import json

# SQSキューのURLを指定します
queue_url = '【SQSのURL】'

# JSONリストを作成します（サンプルデータ）
json_list = [
    {"id": 1, "name": "Alice"},
    {"id": 2, "name": "Bob"},
    {"id": 3, "name": "Charlie"}
]

# SQSクライアントを作成します
sqs = boto3.client('sqs')

# メッセージエントリのリストを作成します
entries = []

# JSONリストをメッセージエントリに変換します
for json_item in json_list:
    # JSONを文字列に変換します
    json_message = json.dumps(json_item)

    # メッセージエントリを作成します
    entry = {
        'Id': str(json_item['id']),  # メッセージのIDはユニークである必要があります
        'MessageBody': json_message
    }

    entries.append(entry)

# メッセージエントリを使用してメッセージを一括送信します
response = sqs.send_message_batch(
    QueueUrl=queue_url,
    Entries=entries
)

# レスポンスを表示します
print("Messages sent:", len(response['Successful']))

確認

• Amazon SQS > キュー → 対象キュー名をクリック
• 「メッセージを送受信」をクリック→「メッセージをポーリング」をクリック
• 受信したメッセージにjson_listで作成したメッセージが確認できればOK