def send_sqs_messages()

in functions/source/s3-to-lifecycle-events-converter/handler.py [0:0]

• 10 lines of code
• 3 McCabe index (conditional complexity)

def send_sqs_messages(messages, queue_url=os.environ['LIFECICLE_EVENTS_QUEUE_URL'], batch_size=int(os.environ.get("BATCH_SIZE", 10))):
    sqs_client = boto3.client('sqs', region_name=os.environ.get("AWS_REGION"))

    for i in range(0, len(messages), batch_size):
        messages_chunk = list(messages)[i:i + batch_size]   
        entries = [{'Id': str(idx), 'MessageBody': json.dumps(msg), 'MessageGroupId': 'lifecycle_events'} for idx,msg in enumerate(messages_chunk)] 

        response = sqs_client.send_message_batch(
            QueueUrl=queue_url,
            Entries=entries
        )

        logger.info(f"Successfully {response}")