sqs-extended-client

import boto3 from sqs_extended_client import SQSExtendedClient session = boto3.Session() sqs_client = session.client('sqs') s3_client = session.client('s3') # Initialize extended client # Use environment variables for credentials in production extended = SQSExtendedClient( sqs_client=sqs_client, s3_client=s3_client, s3_bucket_name='my-large-messages-bucket', # Replace with your bucket always_through_s3=False # Only use S3 when size > 256KB ) # Send a message queue_url = 'https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue' message_body = 'a' * 300000 # Large message response = extended.send_message( QueueUrl=queue_url, MessageBody=message_body ) print('Message sent with SQS message ID:', response['MessageId']) # Receive and process messages messages = extended.receive_message( QueueUrl=queue_url, MaxNumberOfMessages=5 ) for msg in messages: body = msg['Body'] print('Received message body length:', len(body)) extended.delete_message(QueueUrl=queue_url, ReceiptHandle=msg['ReceiptHandle'])