rights reserved. メッセージ受信の実装例( Lambda 関数の場合) def lambda_handler(event, context): for record in event['Records']: # メッセージを使った処理 message_body = record["body"] print(str(message_body)) メッセージ受信側の実装例 # SQS client の作成 sqs = boto3.client('sqs') # キューURL(宛先となるキュー) queue_url = 'SQS_QUEUE_URL' # キューからメッセージを受信 response = sqs.receive_message( QueueUrl=queue_url, MaxNumberOfMessages=10 ) # メッセージの取得 for message in response.get("Messages", []): message_body = message["Body"] # メッセージを使った処理 print(message_body) # メッセージ削除用の受信ハンドルの取得 receipt_handle = message['ReceiptHandle'] # キューから受信したメッセージを削除 sqs.delete_message( QueueUrl=queue_url, ReceiptHandle=receipt_handle ) さらに⾃前で必要 定期的に実⾏するための 仕組み(常駐プロセス) + スケールする仕組み キュー コンシューマ メッセージの受信 ReceiveMessage メッセージの削除 DeleteMessage × n 回 ポーリング シンプル︕