It appears lambdas are not triggered from items being pushed to SQS if [SendMessageBatch](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SendMessageBatch.html) is used instead of [SendMessage](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SendMessage.html)
"""Utility method to create a new queue via SQS API"""
    client = aws_stack.connect_to_service('sqs')
    
    queue_url = client.create_queue(QueueName=queue_name)['QueueUrl']
    
    queue_arn = client.get_queue_attributes(
        QueueUrl=queue_url,
        AttributeNames=['QueueArn'],
    )['Attributes']['QueueArn']
    return {
        'QueueUrl': queue_url,
        'QueueArn': queue_arn,
    }
def get_lambda_log_stream(function_name):
    logs = aws_stack.connect_to_service('logs')
    rs = logs.describe_log_streams(
        logGroupName='/aws/lambda/{}'.format(function_name)
    )
    return rs['logStreams'][0]['logStreamName']
def get_event_message(events):
    for event in events:
        raw_message = event['message']
        if 'START' in raw_message or 'END' in raw_message or 'REPORT' in raw_message:
            continue
        return json.loads(raw_message)
    return None